Class TwitterListMemberReader
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.TwitterListMemberReader
Reads the users of list.
https://dev.twitter.com/rest/reference/get/lists/ownerships
-
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
ConstructorsConstructorDescriptionTwitterListMemberReader(TwitterProvider provider, long listId) TwitterListMemberReader(TwitterProvider provider, String ownerScreenName, String slug) Creates a reader for the members of the list identified by its owner's screen name and slug.TwitterListMemberReader(String consumerKey, String consumerSecret, long listId) TwitterListMemberReader(String consumerKey, String consumerSecret, String userScreenName, String slug) Creates a reader for the members of the list identified by its owner's screen name and slug.TwitterListMemberReader(String consumerKey, String consumerSecret, String accessToken, String accessTokenSecret, long listId) TwitterListMemberReader(String consumerKey, String consumerSecret, String accessToken, String accessTokenSecret, String userScreenName, String slug) Creates a reader for the members of the list identified by its owner's screen name and slug. -
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
-
TwitterListMemberReader
Creates a reader for the members of the list identified by its owner's screen name and slug. -
TwitterListMemberReader
public TwitterListMemberReader(String consumerKey, String consumerSecret, String userScreenName, String slug) Creates a reader for the members of the list identified by its owner's screen name and slug. -
TwitterListMemberReader
public TwitterListMemberReader(String consumerKey, String consumerSecret, String accessToken, String accessTokenSecret, String userScreenName, String slug) Creates a reader for the members of the list identified by its owner's screen name and slug. -
TwitterListMemberReader
-
TwitterListMemberReader
-
TwitterListMemberReader
-
-
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>>
-