| 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 | 
| 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 | 
| Class and Description | 
|---|
| TupleStream | 
Copyright © 2000-2016 Apache Software Foundation. All Rights Reserved.