# 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