## Uses of Class
org.apache.solr.client.solrj.io.stream.TupleStream

Packages that use TupleStream
org.apache.solr.client.solrj.io.graph: Streaming Graph Traversals
org.apache.solr.client.solrj.io.stream: Stream implementations for the Streaming Aggregation API
org.apache.solr.client.solrj.io.stream.expr: Expression language for the Streaming Aggregation API

### Uses of TupleStream in org.apache.solr.client.solrj.io.graph

Subclasses of TupleStream in org.apache.solr.client.solrj.io.graph
`class` `GatherNodesStream`
`class` `ShortestPathStream`

Methods in org.apache.solr.client.solrj.io.graph that return types with arguments of type TupleStream
`List<TupleStream>` ShortestPathStream.`children()`
`List<TupleStream>` GatherNodesStream.`children()`

Constructors in org.apache.solr.client.solrj.io.graph with parameters of type TupleStream
Constructor and Description
`GatherNodesStream(String zkHost, String collection, TupleStream tupleStream, String traverseFrom, String traverseTo, String gather, Map queryParams, List<Metric> metrics, boolean trackTraversal, Set<Traversal.Scatter> scatter, int maxDocFreq)`

### Uses of TupleStream in org.apache.solr.client.solrj.io.stream

Subclasses of TupleStream in org.apache.solr.client.solrj.io.stream
`class` `BiJoinStream` Joins leftStream with rightStream based on a Equalitor.
`class` `CalculatorStream`
`class` `CartesianProductStream`
`class` `CellStream`
`class` `CloudSolrStream` Connects to Zookeeper to pick replicas from a specific collection to send the query to.
`class` `CommitStream` Sends a commit message to a SolrCloud collection
`class` `ComplementStream` Emits tuples from streamA which do not exist in streamB.
`class` `DaemonStream`
`class` `EchoStream`
`class` `EvalStream`
`class` `ExceptionStream`
`class` `ExecutorStream` The executor function wraps a stream with Tuples containing Streaming Expressions and executes them in parallel.
`class` `FacetStream` The FacetStream abstracts the output from the JSON facet API as a Stream of Tuples.
`class` `FeaturesSelectionStream`
`class` `FetchStream` Iterates over a stream and fetches additional fields from a specified collection.
`class` `GetStream`
`class` `HashJoinStream` Takes two streams (fullStream and hashStream) and joins them similar to an InnerJoinStream.
`class` `HavingStream` The HavingStream iterates over an internal stream and applies a BooleanOperation to each tuple.
`class` `InnerJoinStream` Joins leftStream with rightStream based on a Equalitor.
`class` `IntersectStream` Emits tuples from streamA which also exist in streamB.
`class` `JDBCStream` Connects to a datasource using a registered JDBC driver and execute a query.
`class` `JoinStream` Defines a JoinStream which can hold N streams, all joined with the same equalitor
`class` `KnnStream`
`class` `LeftOuterJoinStream` Joins leftStream with rightStream based on a Equalitor.
`class` `LetStream`
`class` `ListStream`
`class` `MergeStream` Merges two or more streams together ordering the Tuples based on a Comparator.
`class` `ModelStream` The ModelStream retrieves a stored model from a Solr Cloud collection.
`class` `NullStream` The NullStream Iterates over a TupleStream and eats the tuples.
`class` `OuterHashJoinStream` Takes two streams (fullStream and hashStream) and joins them similar to an LeftOuterJoinStream.
`class` `ParallelStream` The ParallelStream decorates a TupleStream implementation and pushes it to N workers for parallel execution.
`class` `PriorityStream` The priority function wraps two topics that represent high priority and low priority task queues.
`class` `PushBackStream` A TupleStream that allows a single Tuple to be pushed back onto the stream after it's been read.
`class` `RandomStream` The RandomStream emits a stream of psuedo random Tuples that match the query parameters.
`class` `RankStream` Iterates over a TupleStream and Ranks the topN tuples based on a Comparator.
`class` `ReducerStream` Iterates over a TupleStream and buffers Tuples that are equal based on a comparator.
`class` `RollupStream`
`class` `ScoreNodesStream` Iterates over a gatherNodes() expression and scores the Tuples based on tf-idf.
`class` `SelectStream` Selects fields from the incoming stream and applies optional field renaming.
`class` `ShuffleStream`
`class` `SignificantTermsStream`
`class` `SolrStream` Queries a single Solr instance and maps SolrDocs to a Stream of Tuples.
`class` `SortStream` The SortStream emits a stream of Tuples sorted by a Comparator.
`class` `SqlStream`
`class` `StatsStream`
`class` `TextLogitStream`
`protected static class` `TextLogitStream.TermsStream`
`class` `TimeSeriesStream`
`class` `TopicStream`
`class` `TupStream`
`class` `UniqueStream` The UniqueStream emits a unique stream of Tuples based on a Comparator.
`class` `UpdateStream` Sends tuples emitted by a wrapped `TupleStream` as updates to a SolrCloud collection.

Fields in org.apache.solr.client.solrj.io.stream declared as TupleStream
`protected TupleStream` HashJoinStream.`fullStream`
`protected TupleStream` HashJoinStream.`hashStream`
`protected TupleStream` TextLogitStream.`termsStream`
`protected TupleStream` SqlStream.`tupleStream`

Fields in org.apache.solr.client.solrj.io.stream with type parameters of type TupleStream
`protected List<TupleStream>` CloudSolrStream.`solrStreams`

Methods in org.apache.solr.client.solrj.io.stream that return types with arguments of type TupleStream
`List<TupleStream>` UpdateStream.`children()`
`List<TupleStream>` UniqueStream.`children()`
`List<TupleStream>` TupStream.`children()`
`abstract List<TupleStream>` TupleStream.`children()`
`List<TupleStream>` TopicStream.`children()`
`List<TupleStream>` TimeSeriesStream.`children()`
`List<TupleStream>` TextLogitStream.`children()`
`List<TupleStream>` TextLogitStream.TermsStream.`children()`
`List<TupleStream>` StatsStream.`children()`
`List<TupleStream>` SqlStream.`children()`
`List<TupleStream>` SortStream.`children()`
`List<TupleStream>` SolrStream.`children()`
`List<TupleStream>` SignificantTermsStream.`children()`
`List<TupleStream>` SelectStream.`children()`
`List<TupleStream>` ScoreNodesStream.`children()`
`List<TupleStream>` RollupStream.`children()`
`List<TupleStream>` ReducerStream.`children()`
`List<TupleStream>` RankStream.`children()`
`List<TupleStream>` RandomStream.`children()`
`List<TupleStream>` PushBackStream.`children()`
`List<TupleStream>` PriorityStream.`children()`
`List<TupleStream>` ParallelStream.`children()`
`List<TupleStream>` NullStream.`children()`
`List<TupleStream>` ModelStream.`children()`
`List<TupleStream>` MergeStream.`children()`
`List<TupleStream>` ListStream.`children()`
`List<TupleStream>` LetStream.`children()`
`List<TupleStream>` KnnStream.`children()`
`List<TupleStream>` JoinStream.`children()`
`List<TupleStream>` JDBCStream.`children()`
`List<TupleStream>` IntersectStream.`children()`
`List<TupleStream>` HavingStream.`children()`
`List<TupleStream>` HashJoinStream.`children()`
`List<TupleStream>` GetStream.`children()`
`List<TupleStream>` FetchStream.`children()`
`List<TupleStream>` FeaturesSelectionStream.`children()`
`List<TupleStream>` FacetStream.`children()`
`List<TupleStream>` ExecutorStream.`children()`
`List<TupleStream>` ExceptionStream.`children()`
`List<TupleStream>` EvalStream.`children()`
`List<TupleStream>` EchoStream.`children()`
`List<TupleStream>` DaemonStream.`children()`
`List<TupleStream>` ComplementStream.`children()`
`List<TupleStream>` CommitStream.`children()`
`List<TupleStream>` CloudSolrStream.`children()`
`List<TupleStream>` CellStream.`children()`
`List<TupleStream>` CartesianProductStream.`children()`
`List<TupleStream>` CalculatorStream.`children()`

Methods in org.apache.solr.client.solrj.io.stream with parameters of type TupleStream
`void` DaemonStream.`init(TupleStream tupleStream, String id, long runInterval, int queueSize)`
`void` DaemonStream.`init(TupleStream tupleStream, String id, long runInterval, int queueSize, boolean terminate)`

Constructors in org.apache.solr.client.solrj.io.stream with parameters of type TupleStream
Constructor and Description
`BiJoinStream(TupleStream leftStream, TupleStream rightStream, StreamEqualitor eq)`
`CellStream(String name, TupleStream stream)`
`CommitStream(String collectionName, TupleStream tupleSource, String zkHost, int batchSize, boolean waitFlush, boolean waitSearcher, boolean softCommit)`
`ComplementStream(TupleStream streamA, TupleStream streamB, StreamEqualitor eq)`
`DaemonStream(TupleStream tupleStream, String id, long runInterval, int queueSize)`
`DaemonStream(TupleStream tupleStream, String id, long runInterval, int queueSize, boolean terminate)`
`ExceptionStream(TupleStream stream)`
`FetchStream(String zkHost, String collection, TupleStream tupleStream, String on, String fieldList, int batchSize)`
`HashJoinStream(TupleStream fullStream, TupleStream hashStream, List<String> hashOn)`
`HavingStream(TupleStream stream, BooleanEvaluator evaluator)`
`InnerJoinStream(TupleStream leftStream, TupleStream rightStream, StreamEqualitor eq)`
`IntersectStream(TupleStream streamA, TupleStream streamB, StreamEqualitor eq)`
`JoinStream(StreamEqualitor eq, TupleStream first, TupleStream second, TupleStream... others)`
`JoinStream(StreamEqualitor eq, TupleStream first, TupleStream second, TupleStream... others)`
`LeftOuterJoinStream(TupleStream leftStream, TupleStream rightStream, StreamEqualitor eq)`
`ListStream(TupleStream... streams)`
`MergeStream(StreamComparator comp, TupleStream... streams)`
`MergeStream(TupleStream streamA, TupleStream streamB, StreamComparator comp)`
`NullStream(TupleStream tupleStream)`
`OuterHashJoinStream(TupleStream fullStream, TupleStream hashStream, List<String> hashOn)`
`ParallelStream(String zkHost, String collection, TupleStream tupleStream, int workers, StreamComparator comp)`
`PushBackStream(TupleStream stream)`
`RankStream(TupleStream tupleStream, int size, StreamComparator comp)`
`ReducerStream(TupleStream stream, StreamComparator comp, ReduceOperation op)`
`ReducerStream(TupleStream stream, StreamEqualitor eq, ReduceOperation op)`
`RollupStream(TupleStream tupleStream, Bucket[] buckets, Metric[] metrics)`
`ScoreNodesStream(TupleStream tupleStream, String nodeFreqField)`
`SelectStream(TupleStream stream, List<String> selectedFields)`
`SelectStream(TupleStream stream, Map<String,String> selectedFields)`
`SortStream(TupleStream stream, StreamComparator comp)`
`TextLogitStream(String zkHost, String collectionName, Map params, String name, String field, TupleStream termsStream, List<Double> weights, String outcome, int positiveLabel, double threshold, int maxIterations)`
`UniqueStream(TupleStream stream, StreamEqualitor eq)`
`UpdateStream(String collectionName, TupleStream tupleSource, String zkHost, int updateBatchSize)`

### Uses of TupleStream in org.apache.solr.client.solrj.io.stream.expr

Methods in org.apache.solr.client.solrj.io.stream.expr that return TupleStream
`TupleStream` StreamFactory.`constructStream(StreamExpression expression)`
`TupleStream` StreamFactory.`constructStream(String expressionClause)`