| 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
|
| 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 |
| DaemonStream |
| HashJoinStream
Takes two streams (fullStream and hashStream) and joins them similar to an InnerJoinStream.
|
| JoinStream
Defines a JoinStream which can hold N streams, all joined with the same equalitor
|
| JSONTupleStream |
| 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 |
| Class and Description |
|---|
| TupleStream |
Copyright © 2000-2017 Apache Software Foundation. All Rights Reserved.