org.apache.streams.facebook.provider

Class FacebookDataCollector

java.lang.Object

org.apache.streams.facebook.provider.FacebookDataCollector

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

FacebookPageDataCollector, FacebookPageFeedDataCollector

public abstract class FacebookDataCollector
extends Object
implements Runnable

Abstract data collector for Facebook. Iterates over ids and queues data to be output by a StreamsProvider

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.streams.util.api.requests.backoff.BackOffStrategy	backOff
protected AtomicBoolean	isComplete

Constructor Summary

Constructors

Constructor and Description
FacebookDataCollector(FacebookConfiguration config, BlockingQueue<StreamsDatum> queue) FacebookDataCollector constructor.

Method Summary

Modifier and Type	Method and Description
protected abstract void	getData(IdConfig id) Queries facebook and queues the resulting data.
protected facebook4j.Facebook	getNextFacebookClient() Gets a Facebook client.
protected BlockingQueue<StreamsDatum>	getQueue()
boolean	isComplete() Returns true when the collector has finished querying facebook and has queued all data for the provider.
protected void	outputData(Object data, String id) Queues facebook data.
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

isComplete

protected AtomicBoolean isComplete

backOff

protected org.apache.streams.util.api.requests.backoff.BackOffStrategy backOff

Constructor Detail

FacebookDataCollector

public FacebookDataCollector(FacebookConfiguration config,
                             BlockingQueue<StreamsDatum> queue)

FacebookDataCollector constructor.

Parameters:

config - config

queue - queue

Method Detail

isComplete

public boolean isComplete()

Returns true when the collector has finished querying facebook and has queued all data for the provider.

Returns:

isComplete

outputData

protected void outputData(Object data,
                          String id)

Queues facebook data.

Parameters:

data - data

id - id

getNextFacebookClient

protected facebook4j.Facebook getNextFacebookClient()

Gets a Facebook client. If multiple authenticated users for this app are available it will rotate through the users oauth credentials

Returns:

client

getData

protected abstract void getData(IdConfig id)
                         throws Exception

Queries facebook and queues the resulting data.

Parameters:

id - id

Throws:

Exception - Exception

run

public void run()

Specified by:

run in interface Runnable

getQueue

protected BlockingQueue<StreamsDatum> getQueue()