Class TwitterWriter
java.lang.Object
com.northconcepts.datapipeline.core.DataObject
com.northconcepts.datapipeline.core.Endpoint
com.northconcepts.datapipeline.core.DataEndpoint
com.northconcepts.datapipeline.core.DataWriter
com.northconcepts.datapipeline.internal.lang.IntegrationWriter
com.northconcepts.datapipeline.twitter.TwitterWriter
- Direct Known Subclasses:
TwitterFollowWriter,TwitterUnfollowWriter
Base class for all Twitter DataWriters.
-
Nested Class Summary
Nested classes/interfaces inherited from class com.northconcepts.datapipeline.core.DataEndpoint
DataEndpoint.State -
Field Summary
FieldsFields 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
ConstructorsConstructorDescriptionTwitterWriter(TwitterProvider provider) TwitterWriter(String consumerKey, String consumerSecret) TwitterWriter(String consumerKey, String consumerSecret, String accessToken, String accessTokenSecret) -
Method Summary
Modifier and TypeMethodDescriptionaddExceptionProperties(DataException exception) Adds this endpoint's current state to aDataException.Returns the converter that copies Twitter objects into records (defaults toITwitterConverter.DEFAULT).Returns how multi-valued entity fields are stored (defaults toEntityExpansionPolicy.TO_STRING).setApiLimitPolicy(IApiLimitPolicy apiLimitPolicy) setConverter(ITwitterConverter converter) Sets the converter that copies Twitter objects into records (defaults toITwitterConverter.DEFAULT).setEntityExpansionPolicy(IEntityExpansionPolicy entityExpansionPolicy) Sets how multi-valued entity fields are stored (defaults toEntityExpansionPolicy.TO_STRING).Methods inherited from class com.northconcepts.datapipeline.internal.lang.IntegrationWriter
openMethods inherited from class com.northconcepts.datapipeline.core.DataWriter
available, getNestedEndpoint, getNestedWriter, getRootEndpoint, getRootWriter, getWriter, write, writeImplMethods 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
-
Field Details
-
EOF
-
-
Constructor Details
-
TwitterWriter
-
TwitterWriter
-
TwitterWriter
-
-
Method Details
-
getProvider
-
getApiLimitPolicy
-
setApiLimitPolicy
-
getConverter
Returns the converter that copies Twitter objects into records (defaults toITwitterConverter.DEFAULT). -
setConverter
Sets the converter that copies Twitter objects into records (defaults toITwitterConverter.DEFAULT). -
getEntityExpansionPolicy
Returns how multi-valued entity fields are stored (defaults toEntityExpansionPolicy.TO_STRING). -
setEntityExpansionPolicy
Sets how multi-valued entity fields are stored (defaults toEntityExpansionPolicy.TO_STRING). -
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 classDataWriter
-