| Package | Description |
|---|---|
| org.apache.solr.client.solrj.io |
Streaming Aggregation API
|
| org.apache.solr.client.solrj.io.eval |
Evaluators for the Streaming Aggregation API
|
| 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
|
| Class and Description |
|---|
| StreamContext
The StreamContext is passed to TupleStreams using the TupleStream.setStreamContext() method.
|
| TupleStream |
| Class and Description |
|---|
| StreamContext
The StreamContext is passed to TupleStreams using the TupleStream.setStreamContext() method.
|
| Class and Description |
|---|
| StreamContext
The StreamContext is passed to TupleStreams using the TupleStream.setStreamContext() method.
|
| TupleStream |
| Class and 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.
|
| CloudSolrStream.TupleWrapper |
| CsvStream |
| DaemonStream |
| DeepRandomStream.TupleWrapper |
| HashJoinStream
Takes two streams (fullStream and hashStream) and joins them similar to an InnerJoinStream.
|
| JDBCStream.ResultSetValueSelector |
| JoinStream
Defines a JoinStream which can hold N streams, all joined with the same equalitor
|
| JSONTupleStream |
| ParallelListStream |
| ParallelListStream.StreamIndex |
| ParallelMetricsRollup
Indicates the underlying stream source supports parallelizing metrics computation across collections
using a rollup of metrics from each collection.
|
| PushBackStream
A TupleStream that allows a single Tuple to be pushed back onto the stream after it's been read.
|
| SolrStream
Queries a single Solr instance and maps SolrDocs to a Stream of Tuples.
|
| StreamContext
The StreamContext is passed to TupleStreams using the TupleStream.setStreamContext() method.
|
| TupleStream |
| TupleStreamParser |
| UpdateStream
Sends tuples emitted by a wrapped
TupleStream as updates to a SolrCloud collection. |
| Class and Description |
|---|
| TupleStream |
Copyright © 2000-2021 Apache Software Foundation. All Rights Reserved.