Stream implementations for the Streaming Aggregation API
Interface Summary Interface Description JDBCStream.ResultSetValueSelector ParallelMetricsRollupIndicates the underlying stream source supports parallelizing metrics computation across collections using a rollup of metrics from each collection. TupleStreamParser
Class Summary Class Description BiJoinStreamJoins leftStream with rightStream based on a Equalitor. CalculatorStream CartesianProductStream CellStream CloudSolrStreamConnects to Zookeeper to pick replicas from a specific collection to send the query to. CommitStreamSends a commit message to a SolrCloud collection ComplementStreamEmits tuples from streamA which do not exist in streamB. CsvStream DaemonStream DeepRandomStreamConnects to Zookeeper to pick replicas from a specific collection to send the query to. DeleteStreamUses tuples to identify the uniqueKey values of documents to be deleted DrillStream EchoStream EvalStream ExceptionStream ExecutorStreamThe executor function wraps a stream with Tuples containing Streaming Expressions and executes them in parallel. ExecutorStream.StreamTask Facet2DStream FacetStreamThe FacetStream abstracts the output from the JSON facet API as a Stream of Tuples. FeaturesSelectionStream FetchStreamIterates over a stream and fetches additional fields from a specified collection. GetStream HashJoinStreamTakes two streams (fullStream and hashStream) and joins them similar to an InnerJoinStream. HashRollupStream HavingStreamThe HavingStream iterates over an internal stream and applies a BooleanOperation to each tuple. InnerJoinStreamJoins leftStream with rightStream based on a Equalitor. IntersectStreamEmits tuples from streamA which also exist in streamB. JavabinTupleStreamParser JDBCStreamConnects to a datasource using a registered JDBC driver and execute a query. JoinStreamDefines a JoinStream which can hold N streams, all joined with the same equalitor JSONTupleStream KnnStream LeftOuterJoinStreamJoins leftStream with rightStream based on a Equalitor. LetStream ListStream MergeStreamMerges two or more streams together ordering the Tuples based on a Comparator. ModelStreamThe ModelStream retrieves a stored model from a Solr Cloud collection. NoOpStreamA simple no-operation stream. NullStreamThe NullStream Iterates over a TupleStream and eats the tuples. OuterHashJoinStreamTakes two streams (fullStream and hashStream) and joins them similar to an LeftOuterJoinStream. ParallelListStream ParallelStreamThe ParallelStream decorates a TupleStream implementation and pushes it to N workers for parallel execution. PlotStream PriorityStreamThe priority function wraps two topics that represent high priority and low priority task queues. PushBackStreamA TupleStream that allows a single Tuple to be pushed back onto the stream after it's been read. RandomFacadeStream RandomStreamThe RandomStream emits a stream of pseudo random Tuples that match the query parameters. RankStreamIterates over a TupleStream and Ranks the topN tuples based on a Comparator. ReducerStreamIterates over a TupleStream and buffers Tuples that are equal based on a comparator. RollupStream ScoreNodesStreamIterates over a gatherNodes() expression and scores the Tuples based on tf-idf. SearchFacadeStreamConnects to Zookeeper to pick replicas from a specific collection to send the query to. SearchStream SelectStreamSelects fields from the incoming stream and applies optional field renaming. ShuffleStream SignificantTermsStream SolrStreamQueries a single Solr instance and maps SolrDocs to a Stream of Tuples. SortStreamThe SortStream emits a stream of Tuples sorted by a Comparator. SqlStream StatsStream StreamContextThe StreamContext is passed to TupleStreams using the TupleStream.setStreamContext() method. TextLogitStream TextLogitStream.TermsStream TimeSeriesStream TopicStream TsvStream TupleStream TupStream UniqueStreamThe UniqueStream emits a unique stream of Tuples based on a Comparator. UpdateStreamSends tuples emitted by a wrapped
TupleStreamas updates to a SolrCloud collection.
Exception Summary Exception Description SolrStream.HandledException TupleStream.IgnoreException