Modifier and Type | Class and Description |
---|---|
class |
WikipediaEditsDataset
Streaming dataset based on the Wikipedia/Wikimedia edits published in
real-time on the wikimedia IRC channels.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractIRCStreamDataset<T>
Abstract base class for producing a stream of items from an IRC channel.
|
class |
BasicIRCStreamDataset
Basic streaming dataset from IRC messages.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractTwitterSearchDataset<T>
Calls the
SearchResource.search(Query) function periodically and offers all
discovered Status instances with the underlying
BlockingDroppingBufferedStream . |
class |
AbstractTwitterStatusesFilterDataset<T>
Base class for Live twitter streams based on the live Twitter streaming API.
|
class |
AbstractTwitterStreamDataset<T>
Base class for Live twitter streams based on the live Twitter streaming API.
|
class |
ContextRoundRobinTwitterSearchAPIDataset
Extends the
TwitterSearchDataset to support multiple queries. |
class |
RoundRobinTwitterSearchAPIDataset
Extends the
TwitterSearchDataset to support multiple queries. |
class |
TwitterSearchDataset
A concrete version of the
AbstractTwitterSearchDataset which pushes
the Status s into the stream. |
class |
TwitterStreamDataset
A concrete version of the
AbstractTwitterStreamDataset which pushes
the Status s into the stream. |
class |
TwitterStreamFilterDataset
A concrete version of the
AbstractTwitterStreamDataset which pushes
the Status s into the stream. |
Modifier and Type | Class and Description |
---|---|
class |
BlockingDroppingBufferedStream<T>
Base for a
Stream with an internal buffer based on a
BlockingDroppingQueue . |
class |
BufferedReaderStream |
class |
CollectionStream<T>
Stream based on any Collection of items. |
Modifier and Type | Class and Description |
---|---|
class |
ContextStreamCombiner
|
class |
RoundRobinStreamCombiner<T>
|
class |
StreamCombiner<A,B>
A stream combiner takes two streams and produces a new stream of synchronised
pairs of the stream values.
|
Modifier and Type | Class and Description |
---|---|
class |
MetaPayloadStreamCombiner<AP,AM,BP,BM>
A stream combiner takes two streams and produces a new stream of syncrhonised
pairs of the stream values.
|