Package | Description |
---|---|
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 |
---|
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.