public abstract class TwitterProxyReader extends IntegrationProxyReader
DataEndpoint.State
Modifier and Type | Field and Description |
---|---|
protected static Record |
EOF |
fieldLineage, recordLineage
lastRecord, PRODUCT, PRODUCT_VERSION, VENDOR, XML_INPUT_FACTORY_KEY
BUFFER_SIZE, captureElapsedTime, DEFAULT_READ_BUFFER_SIZE
id, log, name, TIMESTAMP_FORMAT
Constructor and Description |
---|
TwitterProxyReader(String rateLimitResource,
String rateLimitKey,
String consumerKey,
String consumerSecret,
DataReader nestedDataReader) |
TwitterProxyReader(String rateLimitResource,
String rateLimitKey,
String consumerKey,
String consumerSecret,
String accessToken,
String accessTokenSecret,
DataReader nestedDataReader) |
TwitterProxyReader(String rateLimitResource,
String rateLimitKey,
TwitterProvider provider,
DataReader nestedDataReader) |
available, close, getNestedReader, interceptRecord, map, map, readImpl, setNestedDataReader, setNestedDataReader
addLineage, getBufferSize, getNestedEndpoint, getRootEndpoint, getRootReader, isExhausted, isLineageSupported, isSaveLineage, peek, pop, push, read, setSaveLineage, skip
decrementRecordCount, enableJmx, getLastRecord, getRecordCount, getRecordCountAsBigInteger, getRecordCountAsString, incrementRecordCount, isRecordCountBigInteger, resetRecordCount, toString
addElapsedtime, assertClosed, assertNotOpened, assertOpened, finalize, getClosedOn, getDescription, getElapsedTime, getElapsedTimeAsString, getOpenedOn, getOpenElapsedTime, getOpenElapsedTimeAsString, getSelfTime, getSelfTimeAsString, getState, isCaptureElapsedTime, isClosed, isOpen, setCaptureElapsedTime, setDescription
protected static final Record EOF
public TwitterProxyReader(String rateLimitResource, String rateLimitKey, TwitterProvider provider, DataReader nestedDataReader)
public TwitterProxyReader(String rateLimitResource, String rateLimitKey, String consumerKey, String consumerSecret, DataReader nestedDataReader)
public void open() throws DataException
DataEndpoint
open
in class IntegrationProxyReader
DataException
public TwitterProvider getProvider()
public IApiLimitPolicy getApiLimitPolicy()
public TwitterProxyReader setApiLimitPolicy(IApiLimitPolicy apiLimitPolicy)
public final TwitterRateLimit getRateLimit()
protected boolean onRateLimitExceeded()
protected TwitterProxyReader setRateLimitExceeded(boolean rateLimitExceeded)
public boolean isRateLimitExceeded()
public final TwitterRateLimit getRateLimit(boolean autoReload)
public TwitterProxyReader setRateLimit(TwitterResponse response)
public TwitterProxyReader setRateLimit(RateLimitStatus rateLimitStatus)
public final void reloadRateLimit()
public IEntityExpansionPolicy getEntityExpansionPolicy()
public TwitterProxyReader setEntityExpansionPolicy(IEntityExpansionPolicy entityExpansionPolicy)
public ITwitterConverter getConverter()
public TwitterProxyReader setConverter(ITwitterConverter converter)
public DataException addExceptionProperties(DataException exception)
Endpoint
DataException
. Since this method is called whenever an
exception is thrown, subclasses should override it to add their specific information.addExceptionProperties
in class ProxyReader
Copyright (c) 2006-2024 North Concepts Inc. All Rights Reserved.