Uses of Interface
org.openimaj.util.stream.Stream

Packages that use Stream

Package	Description
org.openimaj.data.dataset
org.openimaj.stream.provider
org.openimaj.stream.provider.irc
org.openimaj.stream.provider.twitter
org.openimaj.util.stream
org.openimaj.util.stream.combine
org.openimaj.util.stream.window

Uses of Stream in org.openimaj.data.dataset

Subinterfaces of Stream in org.openimaj.data.dataset

Modifier and Type	Interface and Description
interface	StreamingDataset<INSTANCE> A Dataset backed by a Stream of data.

Uses of Stream in org.openimaj.stream.provider

Classes in org.openimaj.stream.provider that implement Stream

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.

Uses of Stream in org.openimaj.stream.provider.irc

Classes in org.openimaj.stream.provider.irc that implement Stream

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.

Uses of Stream in org.openimaj.stream.provider.twitter

Classes in org.openimaj.stream.provider.twitter that implement Stream

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 Statuss into the stream.
class	TwitterStreamDataset A concrete version of the AbstractTwitterStreamDataset which pushes the Statuss into the stream.
class	TwitterStreamFilterDataset A concrete version of the AbstractTwitterStreamDataset which pushes the Statuss into the stream.

Uses of Stream in org.openimaj.util.stream

Classes in org.openimaj.util.stream that implement Stream

Modifier and Type	Class and Description
class	AbstractStream<T> Abstract base implementation of a read-only (i.e.
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.

Methods in org.openimaj.util.stream that return Stream

Modifier and Type	Method and Description
Stream<T>	Stream.filter(Predicate<T> filter) Transform the stream by creating a view that consists of only the items that match the given Predicate.
Stream<T>	AbstractStream.filter(Predicate<T> filter)
<R> Stream<R>	Stream.map(Function<T,R> mapper) Transform the stream by creating a new stream that transforms the items in this stream with the given Function.
<R> Stream<R>	AbstractStream.map(Function<T,R> mapper)
<R> Stream<R>	Stream.map(MultiFunction<T,R> mapper) Transform the stream by creating a new stream that transforms the items in this stream with the given Function.
<R> Stream<R>	AbstractStream.map(MultiFunction<T,R> mapper)
<R> Stream<R>	Stream.transform(Function<Stream<T>,Stream<R>> transform) Transform the stream using the given function to transform the items in this stream.
<R> Stream<R>	AbstractStream.transform(Function<Stream<T>,Stream<R>> transform)

Method parameters in org.openimaj.util.stream with type arguments of type Stream

Modifier and Type	Method and Description
<R> Stream<R>	Stream.transform(Function<Stream<T>,Stream<R>> transform) Transform the stream using the given function to transform the items in this stream.
<R> Stream<R>	Stream.transform(Function<Stream<T>,Stream<R>> transform) Transform the stream using the given function to transform the items in this stream.
<R> Stream<R>	AbstractStream.transform(Function<Stream<T>,Stream<R>> transform)
<R> Stream<R>	AbstractStream.transform(Function<Stream<T>,Stream<R>> transform)

Uses of Stream in org.openimaj.util.stream.combine

Classes in org.openimaj.util.stream.combine that implement Stream

Modifier and Type	Class and Description
class	ContextStreamCombiner A stream combiner takes two streams of Context objects and produces a new stream of Contexts which contain the stream values from both input streams.
class	RoundRobinStreamCombiner<T> Given a List of streams of a given type, present a stream of that type which asks each stream in the List for an item in turn.
class	StreamCombiner<A,B> A stream combiner takes two streams and produces a new stream of synchronised pairs of the stream values.

Methods in org.openimaj.util.stream.combine that return Stream

Modifier and Type	Method and Description
static Stream<Context>	ContextStreamCombiner.combine(Stream<Context> a, Stream<Context> b) Utility method to combine two streams.

Methods in org.openimaj.util.stream.combine with parameters of type Stream

Modifier and Type	Method and Description
static <A,B> StreamCombiner<A,B>	StreamCombiner.combine(Stream<A> a, Stream<B> b) Create a new StreamCombiner from the given streams
static <A,B> StreamCombiner<A,B>	StreamCombiner.combine(Stream<A> a, Stream<B> b) Create a new StreamCombiner from the given streams
static Stream<Context>	ContextStreamCombiner.combine(Stream<Context> a, Stream<Context> b) Utility method to combine two streams.
static Stream<Context>	ContextStreamCombiner.combine(Stream<Context> a, Stream<Context> b) Utility method to combine two streams.

Constructors in org.openimaj.util.stream.combine with parameters of type Stream

Constructor and Description
ContextStreamCombiner(Stream<Context> a, Stream<Context> b) Construct the combiner to consume the two given streams.
ContextStreamCombiner(Stream<Context> a, Stream<Context> b) Construct the combiner to consume the two given streams.
ContextStreamCombiner(Stream<Context> a, Stream<Context> b, String aprefix, String bprefix) Construct the combiner to consume the two given streams, using the given prefixes to modify the keys from the respective streams.
ContextStreamCombiner(Stream<Context> a, Stream<Context> b, String aprefix, String bprefix) Construct the combiner to consume the two given streams, using the given prefixes to modify the keys from the respective streams.
StreamCombiner(Stream<A> a, Stream<B> b)
StreamCombiner(Stream<A> a, Stream<B> b)

Constructor parameters in org.openimaj.util.stream.combine with type arguments of type Stream

Constructor and Description
RoundRobinStreamCombiner(List<Stream<T>> streams) Construct with the given streams.

Uses of Stream in org.openimaj.util.stream.window

Classes in org.openimaj.util.stream.window that implement Stream

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.

Methods in org.openimaj.util.stream.window that return Stream

Modifier and Type	Method and Description
Stream<Context>	ContextRealTimeWindowFunction.apply(Stream<IN> inner)
Stream<Window<IN,Long>>	RealTimeWindowFunction.apply(Stream<IN> inner)
Stream<T>	SequentialStreamAggregator.apply(Stream<T> inner)

Methods in org.openimaj.util.stream.window with parameters of type Stream

Modifier and Type	Method and Description
Stream<Context>	ContextRealTimeWindowFunction.apply(Stream<IN> inner)
Stream<Window<IN,Long>>	RealTimeWindowFunction.apply(Stream<IN> inner)
Stream<T>	SequentialStreamAggregator.apply(Stream<T> inner)
static <AP,AM,BP,BM> MetaPayloadStreamCombiner<AP,AM,BP,BM>	MetaPayloadStreamCombiner.combine(Stream<? extends MetaPayload<AP,AM>> a, Stream<? extends MetaPayload<BP,BM>> b)
static <AP,AM,BP,BM> MetaPayloadStreamCombiner<AP,AM,BP,BM>	MetaPayloadStreamCombiner.combine(Stream<? extends MetaPayload<AP,AM>> a, Stream<? extends MetaPayload<BP,BM>> b)

Constructors in org.openimaj.util.stream.window with parameters of type Stream

Constructor and Description
MetaPayloadStreamCombiner(Stream<A> a, Stream<? extends MetaPayload<BP,BM>> b)
MetaPayloadStreamCombiner(Stream<A> a, Stream<? extends MetaPayload<BP,BM>> b)