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

Streaming Aggregation API

See: Description

Class Summary
Class | Description
--- | ---
AscFieldComp | An ascending field Comparator which compares a field of two Tuples and determines sort order.
CloudSolrStream | Connects to Zookeeper to pick replicas from a specific collection to send the query to.
DescFieldComp | An descending field Comparator which compares a field of two Tuples and determines sort order.
JSONTupleStream |
MergeStream | Unions streamA with streamB ordering the Tuples based on a Comparator.
MultiComp | Wraps multiple Comparators to provide sub-sorting.
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.
SolrClientCache | The SolrClientCache caches SolrClients so they can be reused by different TupleStreams.
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.
Tuple | A simple abstraction of a record containing key/value pairs.
TupleStream |
UniqueStream | The UniqueStream emits a unique stream of Tuples based on a Comparator.

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

Streaming Aggregation API