public class FacebookUserstreamProvider extends Object implements StreamsProvider, Serializable
Modifier and Type | Field and Description |
---|---|
protected facebook4j.Facebook |
client |
protected org.joda.time.DateTime |
end |
protected ExecutorService |
executor |
protected ReadWriteLock |
lock |
protected Queue<StreamsDatum> |
providerQueue |
protected AtomicBoolean |
running |
protected org.joda.time.DateTime |
start |
Constructor and Description |
---|
FacebookUserstreamProvider()
FacebookUserstreamProvider constructor.
|
FacebookUserstreamProvider(Class klass)
FacebookUserstreamProvider constructor.
|
FacebookUserstreamProvider(FacebookUserstreamConfiguration config)
FacebookUserstreamProvider constructor.
|
FacebookUserstreamProvider(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
protected facebook4j.Facebook client
public FacebookUserstreamProvider()
public FacebookUserstreamProvider(FacebookUserstreamConfiguration config)
config
- configpublic FacebookUserstreamProvider(Class klass)
klass
- output Classpublic FacebookUserstreamProvider(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.