com.northconcepts.datapipeline.twitter.TwitterFollowingIDsReader

public class TwitterFollowingIDsReader extends TwitterPageableReader<Long,IDs>

Reads the IDs of accounts a specified account follows.

Nested Class Summary

Nested classes/interfaces inherited from class com.northconcepts.datapipeline.twitter.TwitterPageableReader
TwitterPageableReader.Direction

Nested classes/interfaces inherited from class com.northconcepts.datapipeline.core.DataEndpoint
DataEndpoint.State
Field Summary

Fields inherited from class com.northconcepts.datapipeline.twitter.TwitterPageableReader
FIRST_PAGE

Fields inherited from class com.northconcepts.datapipeline.twitter.TwitterReader
EOF

Fields inherited from class com.northconcepts.datapipeline.core.DataReader
fieldLineage, recordLineage

Fields inherited from class com.northconcepts.datapipeline.core.DataEndpoint
lastRecord, PRODUCT, PRODUCT_VERSION, VENDOR, XML_INPUT_FACTORY_KEY

Fields inherited from class com.northconcepts.datapipeline.core.Endpoint
BUFFER_SIZE, captureElapsedTime, DEFAULT_READ_BUFFER_SIZE

Fields inherited from class com.northconcepts.datapipeline.core.DataObject
id, log, name, TIMESTAMP_FORMAT
Constructor Summary

Constructors

Constructor

Description

TwitterFollowingIDsReader(TwitterProvider provider, String userScreenName)

TwitterFollowingIDsReader(String consumerKey, String consumerSecret, String userScreenName)

TwitterFollowingIDsReader(String consumerKey, String consumerSecret, String accessToken, String accessTokenSecret, String userScreenName)
Method Summary

Modifier and Type

Method

Description

DataException

addExceptionProperties(DataException exception)

Adds this endpoint's current state to a DataException.

protected void

addPageToBuffer(IDs list, LinkedList<Long> buffer)

Appends the elements of a fetched page to the buffer of elements still to be returned.

protected void

copyToRecord(Long id, Record record, IEntityExpansionPolicy entityExpansionPolicy)

Populates a new, empty record from one buffered element.

protected IDs

getPageImpl(long page, int pageSize)

Fetches the page at the given cursor, requesting pageSize elements.

Methods inherited from class com.northconcepts.datapipeline.twitter.TwitterPageableReader
getDirection, getPage, getPageSize, getStartingOffset, open, readImpl, setApiLimitPolicy, setDirection, setStartingOffset

Methods inherited from class com.northconcepts.datapipeline.twitter.TwitterReader
getApiLimitPolicy, getConverter, getEntityExpansionPolicy, getProvider, getRateLimit, getRateLimit, isRateLimitExceeded, onRateLimitExceeded, reloadRateLimit, setConverter, setEntityExpansionPolicy, setRateLimit, setRateLimit, setRateLimitExceeded

Methods inherited from class com.northconcepts.datapipeline.core.DataReader
addLineage, available, getBufferSize, getNestedEndpoint, getNestedReader, getReader, getRootEndpoint, getRootReader, isExhausted, isLineageSupported, isSaveLineage, peek, pop, push, read, setSaveLineage, skip

Methods inherited from class com.northconcepts.datapipeline.core.DataEndpoint
close, decrementRecordCount, enableJmx, getLastRecord, getRecordCount, getRecordCountAsBigInteger, getRecordCountAsString, incrementRecordCount, isRecordCountBigInteger, resetRecordCount, toString

Methods 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

Methods inherited from class com.northconcepts.datapipeline.core.DataObject
exception, exception, exception, getId, getName, resetID

Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details
- TwitterFollowingIDsReader
  
  public TwitterFollowingIDsReader(TwitterProvider provider, String userScreenName)
- TwitterFollowingIDsReader
  
  public TwitterFollowingIDsReader(String consumerKey, String consumerSecret, String userScreenName)
- TwitterFollowingIDsReader
  
  public TwitterFollowingIDsReader(String consumerKey, String consumerSecret, String accessToken, String accessTokenSecret, String userScreenName)
Method Details
- getPageImpl
  
  protected IDs getPageImpl(long page, int pageSize) throws Throwable
  
  Description copied from class: TwitterPageableReader
  
  Fetches the page at the given cursor, requesting pageSize elements.
  
  Specified by:
  
  getPageImpl in class TwitterPageableReader<Long,IDs>
  
  Throws:
  
  Throwable
- addPageToBuffer
  
  protected void addPageToBuffer(IDs list, LinkedList<Long> buffer) throws Throwable
  
  Description copied from class: TwitterPageableReader
  
  Appends the elements of a fetched page to the buffer of elements still to be returned.
  
  Specified by:
  
  addPageToBuffer in class TwitterPageableReader<Long,IDs>
  
  Throws:
  
  Throwable
- copyToRecord
  
  protected void copyToRecord(Long id, Record record, IEntityExpansionPolicy entityExpansionPolicy) throws Throwable
  
  Description copied from class: TwitterPageableReader
  
  Populates a new, empty record from one buffered element.
  
  Specified by:
  
  copyToRecord in class TwitterPageableReader<Long,IDs>
  
  Throws:
  
  Throwable
- addExceptionProperties
  
  public DataException addExceptionProperties(DataException exception)
  
  Description copied from class: Endpoint
  
  Adds this endpoint's current state to a DataException. Since this method is called whenever an exception is thrown, subclasses should override it to add their specific information.
  
  Overrides:
  
  addExceptionProperties in class TwitterPageableReader<Long,IDs>

Class TwitterFollowingIDsReader

Nested Class Summary

Nested classes/interfaces inherited from class com.northconcepts.datapipeline.twitter.TwitterPageableReader

Nested classes/interfaces inherited from class com.northconcepts.datapipeline.core.DataEndpoint

Field Summary

Fields inherited from class com.northconcepts.datapipeline.twitter.TwitterPageableReader

Fields inherited from class com.northconcepts.datapipeline.twitter.TwitterReader

Fields inherited from class com.northconcepts.datapipeline.core.DataReader

Fields inherited from class com.northconcepts.datapipeline.core.DataEndpoint

Fields inherited from class com.northconcepts.datapipeline.core.Endpoint

Fields inherited from class com.northconcepts.datapipeline.core.DataObject

Constructor Summary

Method Summary

Methods inherited from class com.northconcepts.datapipeline.twitter.TwitterPageableReader

Methods inherited from class com.northconcepts.datapipeline.twitter.TwitterReader

Methods inherited from class com.northconcepts.datapipeline.core.DataReader

Methods inherited from class com.northconcepts.datapipeline.core.DataEndpoint

Methods inherited from class com.northconcepts.datapipeline.core.Endpoint

Methods inherited from class com.northconcepts.datapipeline.core.DataObject

Methods inherited from class java.lang.Object

Constructor Details

TwitterFollowingIDsReader

TwitterFollowingIDsReader

TwitterFollowingIDsReader

Method Details

getPageImpl

addPageToBuffer

copyToRecord

addExceptionProperties