public class TwitterStreamDataset extends AbstractTwitterStreamDataset<twitter4j.Status>
AbstractTwitterStreamDataset which pushes
the Statuss into the stream.| Constructor and Description |
|---|
TwitterStreamDataset(TwitterAPIToken token)
Construct the dataset from the given API token.
|
TwitterStreamDataset(TwitterAPIToken token,
BlockingDroppingQueue<twitter4j.Status> buffer)
Construct the dataset from the given API token and buffer.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
registerStatus(twitter4j.Status status,
String json)
Handle the given incoming status and optionally
BlockingDroppingBufferedStream.register(Object)
it with the stream. |
getRandomInstance, numInstancesclose, getBuffer, hasNext, next, registerfilter, forEach, forEach, forEach, iterator, map, map, parallelForEach, parallelForEach, remove, transformclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitfilter, forEach, forEach, forEach, map, map, parallelForEach, parallelForEach, transformforEachRemaining, hasNext, next, removeforEach, iterator, spliteratorpublic TwitterStreamDataset(TwitterAPIToken token)
ArrayBlockingDroppingQueue with a single item capacity.token - the Twitter api authentication credentialspublic TwitterStreamDataset(TwitterAPIToken token, BlockingDroppingQueue<twitter4j.Status> buffer)
token - the Twitter api authentication credentialsbuffer - the buffer to hold Statuss before they are consumed.protected void registerStatus(twitter4j.Status status, String json) throws InterruptedException
AbstractTwitterStreamDatasetBlockingDroppingBufferedStream.register(Object)
it with the stream.registerStatus in class AbstractTwitterStreamDataset<twitter4j.Status>status - the parsed Statusjson - the json stringInterruptedException