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

Stream implementations for the Streaming Aggregation API

See: Description

Class Summary

Class	Description
BiJoinStream	Joins leftStream with rightStream based on a Equalitor.
CloudSolrStream	Connects to Zookeeper to pick replicas from a specific collection to send the query to.
ComplementStream	Emits tuples from streamA which do not exist in streamB.
DaemonStream
ExceptionStream
FacetStream	The FacetStream abstracts the output from the JSON facet API as a Stream of Tuples.
HashJoinStream	Takes two streams (fullStream and hashStream) and joins them similar to an InnerJoinStream.
InnerJoinStream	Joins leftStream with rightStream based on a Equalitor.
IntersectStream	Emits tuples from streamA which also exist in streamB.
JDBCStream	Connects to a datasource using a registered JDBC driver and execute a query.
JoinStream	Defines a JoinStream which can hold N streams, all joined with the same equalitor
JSONTupleStream
LeftOuterJoinStream	Joins leftStream with rightStream based on a Equalitor.
MergeStream	Merges two or more streams together ordering the Tuples based on a Comparator.
OuterHashJoinStream	Takes two streams (fullStream and hashStream) and joins them similar to an LeftOuterJoinStream.
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.
RollupStream
SelectStream	Selects fields from the incoming stream and applies optional field renaming.
SolrStream	Queries a single Solr instance and maps SolrDocs to a Stream of Tuples.
StatsStream
StreamContext	The StreamContext is passed to TupleStreams using the TupleStream.setStreamContext() method.
TopicStream
TupleStream
UniqueStream	The UniqueStream emits a unique stream of Tuples based on a Comparator.
UpdateStream	Sends tuples emitted by a wrapped TupleStream as updates to a SolrCloud collection.

Exception Summary

Exception	Description
SolrStream.HandledException

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

Stream implementations for the Streaming Aggregation API