public class FacebookFriendFeedProvider extends Object implements StreamsProvider, Serializable
Modifier and Type | Field and Description |
---|---|
protected org.joda.time.DateTime |
end |
protected ExecutorService |
executor |
protected Iterator<String[]> |
idsBatches |
protected ReadWriteLock |
lock |
protected Queue<StreamsDatum> |
providerQueue |
protected AtomicBoolean |
running |
protected org.joda.time.DateTime |
start |
Constructor and Description |
---|
FacebookFriendFeedProvider()
FacebookFriendFeedProvider constructor - resolves FacebookUserInformationConfiguration from JVM 'facebook'.
|
FacebookFriendFeedProvider(Class klass)
FacebookFriendFeedProvider constructor - output supplied Class.
|
FacebookFriendFeedProvider(FacebookUserstreamConfiguration config)
FacebookFriendFeedProvider constructor - uses supplied FacebookUserInformationConfiguration.
|
FacebookFriendFeedProvider(FacebookUserstreamConfiguration config,
Class klass) |
Modifier and Type | Method and Description |
---|---|
void |
cleanUp() |
FacebookUserstreamConfiguration |
getConfig() |
protected facebook4j.Facebook |
getFacebookClient() |
String |
getId() |
Queue<StreamsDatum> |
getProviderQueue() |
boolean |
isRunning() |
void |
prepare(Object configurationObject) |
StreamsResultSet |
readCurrent() |
StreamsResultSet |
readNew(BigInteger sequence) |
StreamsResultSet |
readRange(org.joda.time.DateTime start,
org.joda.time.DateTime end) |
void |
setConfig(FacebookUserstreamConfiguration config) |
void |
startStream() |
protected final ReadWriteLock lock
protected volatile Queue<StreamsDatum> providerQueue
protected ExecutorService executor
protected org.joda.time.DateTime start
protected org.joda.time.DateTime end
protected final AtomicBoolean running
public FacebookFriendFeedProvider()
public FacebookFriendFeedProvider(FacebookUserstreamConfiguration config)
public FacebookFriendFeedProvider(Class klass)
klass
- Classpublic FacebookFriendFeedProvider(FacebookUserstreamConfiguration config, Class klass)
public FacebookUserstreamConfiguration getConfig()
public void setConfig(FacebookUserstreamConfiguration config)
public Queue<StreamsDatum> getProviderQueue()
public String getId()
getId
in interface StreamsOperation
public void startStream()
startStream
in interface StreamsProvider
public StreamsResultSet readCurrent()
readCurrent
in interface StreamsProvider
public StreamsResultSet readNew(BigInteger sequence)
readNew
in interface StreamsProvider
public StreamsResultSet readRange(org.joda.time.DateTime start, org.joda.time.DateTime end)
readRange
in interface StreamsProvider
public boolean isRunning()
isRunning
in interface StreamsProvider
public void prepare(Object configurationObject)
prepare
in interface StreamsOperation
protected facebook4j.Facebook getFacebookClient()
public void cleanUp()
cleanUp
in interface StreamsOperation
Copyright © 2018 The Apache Software Foundation. All rights reserved.