org.apache.streams.twitter.processor

Class FetchAndReplaceTwitterProcessor

java.lang.Object

org.apache.streams.twitter.processor.FetchAndReplaceTwitterProcessor

All Implemented Interfaces:

Serializable, StreamsOperation, StreamsProcessor

public class FetchAndReplaceTwitterProcessor
extends Object
implements StreamsProcessor

Given an Activity, fetches the tweet by the activity object id and replaces the existing activity with the converted activity from what is returned by the twitter API.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static int	BACKOFF

Constructor Summary

Constructors

Constructor and Description
FetchAndReplaceTwitterProcessor()
FetchAndReplaceTwitterProcessor(TwitterStreamConfiguration config)

Method Summary

Modifier and Type	Method and Description
void	cleanUp()
protected Tweet	fetch(Activity doc)
protected void	fetchAndReplace(Activity doc, String originalId)
String	getId()
protected Twitter	getTwitterClient()
void	prepare(Object configurationObject)
List<StreamsDatum>	process(StreamsDatum entry)
protected void	replace(Activity doc, Tweet tweet)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

BACKOFF

public static final int BACKOFF

See Also:

Constant Field Values

Constructor Detail

FetchAndReplaceTwitterProcessor

public FetchAndReplaceTwitterProcessor()

FetchAndReplaceTwitterProcessor

public FetchAndReplaceTwitterProcessor(TwitterStreamConfiguration config)

Method Detail

getId

public String getId()

Specified by:

getId in interface StreamsOperation

process

public List<StreamsDatum> process(StreamsDatum entry)

Specified by:

process in interface StreamsProcessor

prepare

public void prepare(Object configurationObject)

Specified by:

prepare in interface StreamsOperation

cleanUp

public void cleanUp()

Specified by:

cleanUp in interface StreamsOperation

fetchAndReplace

protected void fetchAndReplace(Activity doc,
                               String originalId)
                        throws IOException,
                               ActivityConversionException

Throws:

IOException

ActivityConversionException

replace

protected void replace(Activity doc,
                       Tweet tweet)
                throws IOException,
                       ActivityConversionException

Throws:

IOException

ActivityConversionException

fetch

protected Tweet fetch(Activity doc)

getTwitterClient

protected Twitter getTwitterClient()
                            throws InstantiationException

Throws:

InstantiationException