Class GoogleCalendarReader
java.lang.Object
com.northconcepts.datapipeline.core.DataObject
com.northconcepts.datapipeline.core.Endpoint
com.northconcepts.datapipeline.core.DataEndpoint
com.northconcepts.datapipeline.core.DataReader
com.northconcepts.datapipeline.internal.lang.IntegrationReader
com.northconcepts.datapipeline.google.GoogleApiReader
com.northconcepts.datapipeline.google.calendar.GoogleCalendarReader
Reads the events of a Google Calendar, one record per event with its details, attendees, attachments, conference data and
calendar properties.
-
Nested Class Summary
Nested classes/interfaces inherited from class com.northconcepts.datapipeline.core.DataEndpoint
DataEndpoint.State -
Field Summary
Fields inherited from class com.northconcepts.datapipeline.google.GoogleApiReader
credentials, JSON_FACTORY, transportFields inherited from class com.northconcepts.datapipeline.core.DataReader
fieldLineage, recordLineageFields inherited from class com.northconcepts.datapipeline.core.DataEndpoint
lastRecord, PRODUCT, PRODUCT_VERSION, VENDOR, XML_INPUT_FACTORY_KEYFields inherited from class com.northconcepts.datapipeline.core.Endpoint
BUFFER_SIZE, captureElapsedTime, DEFAULT_READ_BUFFER_SIZEFields inherited from class com.northconcepts.datapipeline.core.DataObject
id, log, name, TIMESTAMP_FORMAT -
Constructor Summary
ConstructorsConstructorDescriptionGoogleCalendarReader(Credential credential, HttpTransport httpTransport) Creates a reader that uses the caller's transport, which is not shut down on close. -
Method Summary
Modifier and TypeMethodDescriptionaddExceptionProperties(DataException exception) Adds this endpoint's current state to aDataException.voidclose()Indicates that this endpoint has finished reading or writing.intReturns the number of events requested per page (defaults to 50).Returns the ID of the calendar to read (defaults to"primary").Returns the pending error recorded by this reader (such as a failed batch request) or null; the next read throws it.Returns the order in which events are requested (defaults to"startTime").booleanIndicates thealwaysIncludeEmailvalue of the events request (default is true).booleanIndicates thesingleEventsvalue of the events request (default is true).voidopen()Makes this endpoint ready for reading or writing.protected RecordreadImpl()Overridden by subclasses to read the next record from thisDataReader.setAlwaysIncludeEmail(boolean alwaysIncludeEmail) Indicates thealwaysIncludeEmailvalue of the events request (default is true).setBatchSize(int batchSize) Sets the number of events requested per page, from 1 to 100 (defaults to 50).setCalendarId(String calendarId) Sets the ID of the calendar to read (defaults to"primary").setOrderBy(String orderBy) Sets the order in which events are requested (defaults to"startTime").setSingleEvent(boolean singleEvent) Indicates thesingleEventsvalue of the events request (default is true).setTimeMax(Date timeMax) setTimeMin(Date timeMin) setUpdatedMin(Date updatedMin) Methods inherited from class com.northconcepts.datapipeline.google.GoogleApiReader
getApplicationName, setApplicationName, setJsonFactory, toDate, toExceptionMethods inherited from class com.northconcepts.datapipeline.core.DataReader
addLineage, available, getBufferSize, getNestedEndpoint, getNestedReader, getReader, getRootEndpoint, getRootReader, isExhausted, isLineageSupported, isSaveLineage, peek, pop, push, read, setSaveLineage, skipMethods inherited from class com.northconcepts.datapipeline.core.DataEndpoint
decrementRecordCount, enableJmx, getLastRecord, getRecordCount, getRecordCountAsBigInteger, getRecordCountAsString, incrementRecordCount, isRecordCountBigInteger, resetRecordCount, toStringMethods inherited from class com.northconcepts.datapipeline.core.Endpoint
addElapsedtime, assertClosed, assertNotOpened, assertOpened, finalize, getClosedOn, getDescription, getElapsedTime, getElapsedTimeAsString, getOpenedOn, getOpenElapsedTime, getOpenElapsedTimeAsString, getSelfTime, getSelfTimeAsString, getState, isCaptureElapsedTime, isClosed, isOpen, setCaptureElapsedTime, setDescription
-
Constructor Details
-
GoogleCalendarReader
public GoogleCalendarReader(Credential credential, HttpTransport httpTransport) Creates a reader that uses the caller's transport, which is not shut down on close.
-
-
Method Details
-
getBatchSize
public int getBatchSize()Returns the number of events requested per page (defaults to 50). -
setBatchSize
Sets the number of events requested per page, from 1 to 100 (defaults to 50). -
getTimeMin
-
setTimeMin
-
getTimeMax
-
setTimeMax
-
getUpdatedMin
-
setUpdatedMin
-
getCalendarId
Returns the ID of the calendar to read (defaults to"primary"). -
setCalendarId
Sets the ID of the calendar to read (defaults to"primary"). -
getOrderBy
Returns the order in which events are requested (defaults to"startTime"). -
setOrderBy
Sets the order in which events are requested (defaults to"startTime"). -
isSingleEvent
public boolean isSingleEvent()Indicates thesingleEventsvalue of the events request (default is true). -
setSingleEvent
Indicates thesingleEventsvalue of the events request (default is true). -
isAlwaysIncludeEmail
public boolean isAlwaysIncludeEmail()Indicates thealwaysIncludeEmailvalue of the events request (default is true). -
setAlwaysIncludeEmail
Indicates thealwaysIncludeEmailvalue of the events request (default is true). -
getException
Returns the pending error recorded by this reader (such as a failed batch request) or null; the next read throws it. -
open
Description copied from class:DataEndpointMakes this endpoint ready for reading or writing.- Overrides:
openin classIntegrationReader- Throws:
DataException
-
close
Description copied from class:DataEndpointIndicates that this endpoint has finished reading or writing.- Overrides:
closein classGoogleApiReader- Throws:
DataException
-
readImpl
Description copied from class:DataReaderOverridden by subclasses to read the next record from thisDataReader. The default implementation ofDataReader.read()now insures that this method will not be called again after it returns anull.If no record is available,
nullwill be returned.Contract for subclasses (see also
docs/authoring/DataReader.md):- Return
nullexactly once to signal end-of-stream. - Do not call this method directly —
DataReader.read()is the template method that wraps exceptions, increments the record count, and tracks lineage. - Do not call
DataEndpoint.incrementRecordCount()here;DataReader.read()already does. - Throw raw exceptions;
DataReader.read()wraps them viaexception(throwable).
- Specified by:
readImplin classDataReader- Throws:
Throwable
- Return
-
addExceptionProperties
Description copied from class:EndpointAdds this endpoint's current state to aDataException. Since this method is called whenever an exception is thrown, subclasses should override it to add their specific information.- Overrides:
addExceptionPropertiesin classGoogleApiReader
-