Package | Description |
---|---|
org.openimaj.stream.provider | |
org.openimaj.stream.provider.irc | |
org.openimaj.stream.provider.twitter | |
org.openimaj.util.concurrent | |
org.openimaj.util.stream |
Constructor and Description |
---|
WikipediaEditsDataset(BlockingDroppingQueue<WikipediaEditsDataset.WikipediaEdit> buffer,
String language)
Construct the edit stream with the given buffer and language.
|
Constructor and Description |
---|
AbstractIRCStreamDataset(BlockingDroppingQueue<T> buffer,
String hostname,
String channel) |
BasicIRCStreamDataset(BlockingDroppingQueue<Context> buffer,
String hostname,
String channel)
Construct with the given buffer, connecting to the given host and
channel.
|
Constructor and Description |
---|
AbstractTwitterSearchDataset(TwitterAPIToken token,
BlockingDroppingQueue<T> buffer,
twitter4j.Query query) |
AbstractTwitterStatusesFilterDataset(twitter4j.FilterQuery query,
TwitterAPIToken token,
BlockingDroppingQueue<T> buffer)
Construct with the given Twitter API credentials and buffer
|
AbstractTwitterStreamDataset(TwitterAPIToken token,
BlockingDroppingQueue<T> buffer)
Construct with the given Twitter API credentials and buffer
|
ContextRoundRobinTwitterSearchAPIDataset(List<twitter4j.Query> queries,
TwitterAPIToken token,
BlockingDroppingQueue<Context> buffer) |
RoundRobinTwitterSearchAPIDataset(List<twitter4j.Query> queries,
TwitterAPIToken token,
BlockingDroppingQueue<twitter4j.Status> buffer) |
TwitterSearchDataset(twitter4j.Query query,
TwitterAPIToken token,
BlockingDroppingQueue<twitter4j.Status> buffer)
Construct the dataset from the given API token, query and buffer.
|
TwitterStreamDataset(TwitterAPIToken token,
BlockingDroppingQueue<twitter4j.Status> buffer)
Construct the dataset from the given API token and buffer.
|
TwitterStreamFilterDataset(twitter4j.FilterQuery query,
TwitterAPIToken token,
BlockingDroppingQueue<twitter4j.Status> buffer)
Construct the dataset from the given API token and buffer.
|
Modifier and Type | Class and Description |
---|---|
class |
ArrayBlockingDroppingQueue<E>
A bounded variant of a blocking queue
backed by an array.
|
Modifier and Type | Method and Description |
---|---|
BlockingDroppingQueue<T> |
BlockingDroppingBufferedStream.getBuffer()
Get the underlying
BlockingDroppingQueue that is used as the
internal buffer. |
Constructor and Description |
---|
BlockingDroppingBufferedStream(BlockingDroppingQueue<T> buffer)
Construct with the given backing queue
|