Class TwitterFollowerListReader
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.twitter.TwitterReader
com.northconcepts.datapipeline.twitter.TwitterPageableReader<User,<any>>
com.northconcepts.datapipeline.twitter.TwitterFollowerListReader
Reads the details of accounts following the specified account.
-
Nested Class Summary
Nested classes/interfaces inherited from class com.northconcepts.datapipeline.twitter.TwitterPageableReader
TwitterPageableReader.DirectionNested classes/interfaces inherited from class com.northconcepts.datapipeline.core.DataEndpoint
DataEndpoint.State -
Field Summary
Fields inherited from class com.northconcepts.datapipeline.twitter.TwitterPageableReader
FIRST_PAGEFields inherited from class com.northconcepts.datapipeline.twitter.TwitterReader
EOFFields 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
ConstructorsConstructorDescriptionTwitterFollowerListReader(TwitterProvider provider, String userScreenName) TwitterFollowerListReader(String consumerKey, String consumerSecret, String userScreenName) TwitterFollowerListReader(String consumerKey, String consumerSecret, String accessToken, String accessTokenSecret, String userScreenName) -
Method Summary
Modifier and TypeMethodDescriptionaddExceptionProperties(DataException exception) Adds this endpoint's current state to aDataException.protected voidaddPageToBuffer(<any> list, LinkedList<User> buffer) Appends the elements of a fetched page to the buffer of elements still to be returned.protected voidcopyToRecord(User element, Record record, IEntityExpansionPolicy entityExpansionPolicy) Populates a new, empty record from one buffered element.protected <any>getPageImpl(long page, int pageSize) Fetches the page at the given cursor, requestingpageSizeelements.Methods inherited from class com.northconcepts.datapipeline.twitter.TwitterPageableReader
getDirection, getPage, getPageSize, getStartingOffset, open, readImpl, setApiLimitPolicy, setDirection, setStartingOffsetMethods inherited from class com.northconcepts.datapipeline.twitter.TwitterReader
getApiLimitPolicy, getConverter, getEntityExpansionPolicy, getProvider, getRateLimit, getRateLimit, isRateLimitExceeded, onRateLimitExceeded, reloadRateLimit, setConverter, setEntityExpansionPolicy, setRateLimit, setRateLimit, setRateLimitExceededMethods 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
close, 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
-
TwitterFollowerListReader
-
TwitterFollowerListReader
-
TwitterFollowerListReader
-
-
Method Details
-
getPageImpl
Description copied from class:TwitterPageableReaderFetches the page at the given cursor, requestingpageSizeelements.- Specified by:
getPageImplin classTwitterPageableReader<User,<any>> - Throws:
Throwable
-
addPageToBuffer
Description copied from class:TwitterPageableReaderAppends the elements of a fetched page to the buffer of elements still to be returned.- Specified by:
addPageToBufferin classTwitterPageableReader<User,<any>> - Throws:
Throwable
-
copyToRecord
protected void copyToRecord(User element, Record record, IEntityExpansionPolicy entityExpansionPolicy) throws Throwable Description copied from class:TwitterPageableReaderPopulates a new, empty record from one buffered element.- Specified by:
copyToRecordin classTwitterPageableReader<User,<any>> - Throws:
Throwable
-
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 classTwitterPageableReader<User,<any>>
-