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

Stream implementations for the Streaming Aggregation API

See: Description

Interface Summary
JDBCStream.ResultSetValueSelector
ParallelMetricsRollup: Indicates the underlying stream source supports parallelizing metrics computation across collections using a rollup of metrics from each collection.
TupleStreamParser

Class Summary
BiJoinStream: Joins leftStream with rightStream based on a Equalitor.
CalculatorStream
CartesianProductStream
CellStream
CloudSolrStream: Connects to Zookeeper to pick replicas from a specific collection to send the query to.
CommitStream: Sends a commit message to a SolrCloud collection
ComplementStream: Emits tuples from streamA which do not exist in streamB.
CsvStream
DaemonStream
DeepRandomStream: Connects to Zookeeper to pick replicas from a specific collection to send the query to.
DeleteStream: Uses tuples to identify the uniqueKey values of documents to be deleted
DrillStream
EchoStream
EvalStream
ExceptionStream
ExecutorStream: The executor function wraps a stream with Tuples containing Streaming Expressions and executes them in parallel.
ExecutorStream.StreamTask
Facet2DStream
FacetStream: The FacetStream abstracts the output from the JSON facet API as a Stream of Tuples.
FeaturesSelectionStream
FetchStream: Iterates over a stream and fetches additional fields from a specified collection.
GetStream
HashJoinStream: Takes two streams (fullStream and hashStream) and joins them similar to an InnerJoinStream.
HashRollupStream
HavingStream: The HavingStream iterates over an internal stream and applies a BooleanOperation to each tuple.
InnerJoinStream: Joins leftStream with rightStream based on a Equalitor.
IntersectStream: Emits tuples from streamA which also exist in streamB.
JavabinTupleStreamParser
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
KnnStream
LeftOuterJoinStream: Joins leftStream with rightStream based on a Equalitor.
LetStream
ListStream
MergeStream: Merges two or more streams together ordering the Tuples based on a Comparator.
ModelStream: The ModelStream retrieves a stored model from a Solr Cloud collection.
NoOpStream: A simple no-operation stream.
NullStream: The NullStream Iterates over a TupleStream and eats the tuples.
OuterHashJoinStream: Takes two streams (fullStream and hashStream) and joins them similar to an LeftOuterJoinStream.
ParallelListStream
ParallelStream: The ParallelStream decorates a TupleStream implementation and pushes it to N workers for parallel execution.
PlotStream
PriorityStream: The priority function wraps two topics that represent high priority and low priority task queues.
PushBackStream: A TupleStream that allows a single Tuple to be pushed back onto the stream after it's been read.
RandomFacadeStream
RandomStream: The RandomStream emits a stream of psuedo random Tuples that match the query parameters.
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
ScoreNodesStream: Iterates over a gatherNodes() expression and scores the Tuples based on tf-idf.
SearchFacadeStream: Connects to Zookeeper to pick replicas from a specific collection to send the query to.
SearchStream
SelectStream: Selects fields from the incoming stream and applies optional field renaming.
ShuffleStream
SignificantTermsStream
SolrStream: Queries a single Solr instance and maps SolrDocs to a Stream of Tuples.
SortStream: The SortStream emits a stream of Tuples sorted by a Comparator.
SqlStream
StatsStream
StreamContext: The StreamContext is passed to TupleStreams using the TupleStream.setStreamContext() method.
TextLogitStream
TextLogitStream.TermsStream
TimeSeriesStream
TopicStream
TsvStream
TupleStream
TupStream
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.
ZplotStream

Exception Summary
SolrStream.HandledException
TupleStream.IgnoreException

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

Stream implementations for the Streaming Aggregation API