public class TwitterFollowingProvider extends TwitterUserInformationProvider
Modifier and Type | Field and Description |
---|---|
protected ReadWriteLock |
lock |
static int |
MAX_NUMBER_WAITING |
static String |
STREAMS_ID |
end, executor, idsBatches, providerQueue, running, screenNameBatches, start
Constructor and Description |
---|
TwitterFollowingProvider() |
TwitterFollowingProvider(TwitterFollowingConfiguration config) |
Modifier and Type | Method and Description |
---|---|
void |
addDatum(StreamsDatum datum) |
protected Queue<StreamsDatum> |
constructQueue() |
TwitterFollowingConfiguration |
getConfig() |
void |
prepare(Object o) |
StreamsResultSet |
readCurrent() |
void |
startStream() |
protected void |
submitFollowingThreads(Long[] ids) |
protected void |
submitFollowingThreads(String[] screenNames) |
cleanUp, getId, getProviderQueue, getTwitterClient, isRunning, loadBatch, loadBatch, readNew, readRange, setConfig
public static final String STREAMS_ID
protected final ReadWriteLock lock
public static final int MAX_NUMBER_WAITING
public TwitterFollowingProvider()
public TwitterFollowingProvider(TwitterFollowingConfiguration config)
public TwitterFollowingConfiguration getConfig()
getConfig
in class TwitterUserInformationProvider
public void startStream()
startStream
in interface StreamsProvider
startStream
in class TwitterUserInformationProvider
protected void submitFollowingThreads(Long[] ids)
protected void submitFollowingThreads(String[] screenNames)
public StreamsResultSet readCurrent()
readCurrent
in interface StreamsProvider
readCurrent
in class TwitterUserInformationProvider
protected Queue<StreamsDatum> constructQueue()
public void prepare(Object o)
prepare
in interface StreamsOperation
prepare
in class TwitterUserInformationProvider
public void addDatum(StreamsDatum datum)
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.