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
|
Modifier and Type | Class and Description |
---|---|
class |
CloudSolrStream
Connects to Zookeeper to pick replicas from a specific collection to send the query to.
|
class |
MergeStream
Unions streamA with streamB ordering the Tuples based on a Comparator.
|
class |
ParallelStream
The ParallelStream decorates a TupleStream implementation and pushes it to N workers for parallel execution.
|
class |
PushBackStream
A TupleStream that allows a single Tuple to be pushed back onto the stream after it's been read.
|
class |
RankStream
Iterates over a TupleStream and Ranks the topN tuples based on a Comparator.
|
class |
ReducerStream
Iterates over a TupleStream and buffers Tuples that are equal based on a comparator.
|
class |
SolrStream
Queries a single Solr instance and maps SolrDocs to a Stream of Tuples.
|
class |
UniqueStream
The UniqueStream emits a unique stream of Tuples based on a Comparator.
|
Modifier and Type | Field and Description |
---|---|
protected List<TupleStream> |
CloudSolrStream.solrStreams |
Modifier and Type | Method and Description |
---|---|
List<TupleStream> |
UniqueStream.children() |
abstract List<TupleStream> |
TupleStream.children() |
List<TupleStream> |
SolrStream.children() |
List<TupleStream> |
ReducerStream.children() |
List<TupleStream> |
RankStream.children() |
List<TupleStream> |
PushBackStream.children() |
List<TupleStream> |
ParallelStream.children() |
List<TupleStream> |
MergeStream.children() |
List<TupleStream> |
CloudSolrStream.children() |
Constructor and Description |
---|
MergeStream(TupleStream streamA,
TupleStream streamB,
Comparator<Tuple> comp) |
ParallelStream(String zkHost,
String collection,
TupleStream tupleStream,
int workers,
Comparator<Tuple> comp) |
PushBackStream(TupleStream stream) |
RankStream(TupleStream tupleStream,
int size,
Comparator<Tuple> comp) |
ReducerStream(TupleStream tupleStream,
Comparator<Tuple> comp) |
UniqueStream(TupleStream tupleStream,
Comparator<Tuple> comp) |
Modifier and Type | Method and Description |
---|---|
TupleStream |
StreamFactory.constructStream(StreamExpression expression) |
TupleStream |
StreamFactory.constructStream(String expressionClause) |
Copyright © 2000-2016 Apache Software Foundation. All Rights Reserved.