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

- Packages that use TupleStream
  Package | Description
  --- | ---
  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
    Modifier and Type | Class and Description
    --- | ---
    `class` | `GatherNodesStream`
    `class` | `ShortestPathStream`

    Methods in org.apache.solr.client.solrj.io.graph that return types with arguments of type TupleStream
    Modifier and Type | Method and Description
    --- | ---
    `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
    Modifier and Type | Class and Description
    --- | ---
    `class` | `BiJoinStream` Joins leftStream with rightStream based on a Equalitor.
    `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` | `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` | `HashJoinStream` Takes two streams (fullStream and hashStream) and joins them similar to an InnerJoinStream.
    `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` | `LeftOuterJoinStream` Joins leftStream with rightStream based on a Equalitor.
    `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` | `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` | `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` | `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` | `StatsStream`
    `class` | `TextLogitStream`
    `protected class` | `TextLogitStream.TermsStream`
    `class` | `TopicStream`
    `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
    Modifier and Type | Field and Description
    --- | ---
    `protected TupleStream` | HashJoinStream.`fullStream`
    `protected TupleStream` | HashJoinStream.`hashStream`
    `protected TupleStream` | TextLogitStream.`termsStream`

    Fields in org.apache.solr.client.solrj.io.stream with type parameters of type TupleStream
    Modifier and Type | Field and Description
    --- | ---
    `protected List<TupleStream>` | CloudSolrStream.`solrStreams`

    Methods in org.apache.solr.client.solrj.io.stream that return types with arguments of type TupleStream
    Modifier and Type | Method and Description
    --- | ---
    `List<TupleStream>` | UpdateStream.`children()`
    `List<TupleStream>` | PushBackStream.`children()`
    `List<TupleStream>` | IntersectStream.`children()`
    `List<TupleStream>` | ComplementStream.`children()`
    `List<TupleStream>` | SelectStream.`children()`
    `List<TupleStream>` | FetchStream.`children()`
    `List<TupleStream>` | FacetStream.`children()`
    `List<TupleStream>` | ExecutorStream.`children()`
    `List<TupleStream>` | ModelStream.`children()`
    `abstract List<TupleStream>` | TupleStream.`children()`
    `List<TupleStream>` | SolrStream.`children()`
    `List<TupleStream>` | DaemonStream.`children()`
    `List<TupleStream>` | MergeStream.`children()`
    `List<TupleStream>` | StatsStream.`children()`
    `List<TupleStream>` | SortStream.`children()`
    `List<TupleStream>` | JDBCStream.`children()`
    `List<TupleStream>` | TextLogitStream.`children()`
    `List<TupleStream>` | TextLogitStream.TermsStream.`children()`
    `List<TupleStream>` | ParallelStream.`children()`
    `List<TupleStream>` | JoinStream.`children()`
    `List<TupleStream>` | RankStream.`children()`
    `List<TupleStream>` | UniqueStream.`children()`
    `List<TupleStream>` | FeaturesSelectionStream.`children()`
    `List<TupleStream>` | CloudSolrStream.`children()`
    `List<TupleStream>` | ExceptionStream.`children()`
    `List<TupleStream>` | CommitStream.`children()`
    `List<TupleStream>` | ReducerStream.`children()`
    `List<TupleStream>` | RandomStream.`children()`
    `List<TupleStream>` | ScoreNodesStream.`children()`
    `List<TupleStream>` | HashJoinStream.`children()`
    `List<TupleStream>` | RollupStream.`children()`
    `List<TupleStream>` | TopicStream.`children()`

    Methods in org.apache.solr.client.solrj.io.stream with parameters of type TupleStream
    Modifier and Type | Method and Description
    --- | ---
    `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)`
    `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)`
    `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)`
    `MergeStream(StreamComparator comp, TupleStream... streams)`
    `MergeStream(TupleStream streamA, TupleStream streamB, StreamComparator comp)`
    `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
    Modifier and Type | Method and Description
    --- | ---
    `TupleStream` | StreamFactory.`constructStream(StreamExpression expression)`
    `TupleStream` | StreamFactory.`constructStream(String expressionClause)`

Copyright © 2000-2016 Apache Software Foundation. All Rights Reserved.