org.apache.streams.facebook.provider

Class FacebookProvider

java.lang.Object

org.apache.streams.facebook.provider.FacebookProvider

All Implemented Interfaces:

Serializable, StreamsOperation, StreamsProvider

Direct Known Subclasses:

FacebookPageFeedProvider, FacebookPageProvider

public abstract class FacebookProvider
extends Object
implements StreamsProvider

Abstract StreamsProvider for facebook.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected FacebookConfiguration	configuration
protected BlockingQueue<StreamsDatum>	datums

Constructor Summary

Constructors

Constructor and Description
FacebookProvider() FacebookProvider constructor - resolves FacebookConfiguration from JVM 'facebook'.
FacebookProvider(FacebookConfiguration configuration) FacebookProvider constructor - uses supplied FacebookConfiguration.

Method Summary

Modifier and Type	Method and Description
void	cleanUp()
protected abstract FacebookDataCollector	getDataCollector()
String	getId()
boolean	isRunning()
void	overrideIds(Map<String,org.joda.time.DateTime> idsToAfterDate) Overrides the ids and addedAfter time in the configuration.
void	prepare(Object configurationObject)
StreamsResultSet	readCurrent()
StreamsResultSet	readNew(BigInteger sequence)
StreamsResultSet	readRange(org.joda.time.DateTime start, org.joda.time.DateTime end)
void	startStream()

Methods inherited from class java.lang.Object

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

Field Detail

configuration

protected FacebookConfiguration configuration

datums

protected BlockingQueue<StreamsDatum> datums

Constructor Detail

FacebookProvider

public FacebookProvider()

FacebookProvider constructor - resolves FacebookConfiguration from JVM 'facebook'.

FacebookProvider

public FacebookProvider(FacebookConfiguration configuration)

FacebookProvider constructor - uses supplied FacebookConfiguration.

Method Detail

getId

public String getId()

Specified by:

getId in interface StreamsOperation

startStream

public void startStream()

Specified by:

startStream in interface StreamsProvider

getDataCollector

protected abstract FacebookDataCollector getDataCollector()

readCurrent

public StreamsResultSet readCurrent()

Specified by:

readCurrent in interface StreamsProvider

readNew

public StreamsResultSet readNew(BigInteger sequence)

Specified by:

readNew in interface StreamsProvider

readRange

public StreamsResultSet readRange(org.joda.time.DateTime start,
                                  org.joda.time.DateTime end)

Specified by:

readRange in interface StreamsProvider

prepare

public void prepare(Object configurationObject)

Specified by:

prepare in interface StreamsOperation

cleanUp

public void cleanUp()

Specified by:

cleanUp in interface StreamsOperation

overrideIds

public void overrideIds(Map<String,org.joda.time.DateTime> idsToAfterDate)

Overrides the ids and addedAfter time in the configuration.

Parameters:

idsToAfterDate - idsToAfterDate

isRunning

public boolean isRunning()

Specified by:

isRunning in interface StreamsProvider