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