Package org.apache.solr.client.solrj.io.stream

Stream implementations for the Streaming Aggregation API

See: Description

Interface Summary

Interface	Description
ExpressibleStream	Defines a stream that can be expressed in an expression

Class Summary

Class	Description
CloudSolrStream	Connects to Zookeeper to pick replicas from a specific collection to send the query to.
JSONTupleStream
MergeStream	Unions streamA with streamB ordering the Tuples based on a Comparator.
ParallelStream	The ParallelStream decorates a TupleStream implementation and pushes it to N workers for parallel execution.
PushBackStream	A TupleStream that allows a single Tuple to be pushed back onto the stream after it's been read.
RankStream	Iterates over a TupleStream and Ranks the topN tuples based on a Comparator.
ReducerStream	Iterates over a TupleStream and buffers Tuples that are equal based on a comparator.
SolrStream	Queries a single Solr instance and maps SolrDocs to a Stream of Tuples.
StreamContext	The StreamContext is passed to TupleStreams using the TupleStream.setStreamContext() method.
TupleStream
UniqueStream	The UniqueStream emits a unique stream of Tuples based on a Comparator.

Package org.apache.solr.client.solrj.io.stream Description

Stream implementations for the Streaming Aggregation API