# 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

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