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.
CommitStream	Sends a commit message to a SolrCloud collection
ComplementStream	Emits tuples from streamA which do not exist in streamB.
DaemonStream
ExceptionStream
ExecutorStream	The executor function wraps a stream with Tuples containing Streaming Expressions and executes them in parallel.
ExecutorStream.StreamTask
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.
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.
ModelStream	The ModelStream retrieves a stored model from a Solr Cloud collection.
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.
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.
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.
SortStream	The SortStream emits a stream of Tuples sorted by a Comparator.
StatsStream
StreamContext	The StreamContext is passed to TupleStreams using the TupleStream.setStreamContext() method.
TextLogitStream
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