Class | Description |
---|---|
AscFieldComp |
An ascending field Comparator which compares a field of two Tuples and determines sort order.
|
CloudSolrStream |
Connects to Zookeeper to pick replicas from a specific collection to send the query to.
|
DescFieldComp |
An descending field Comparator which compares a field of two Tuples and determines sort order.
|
JSONTupleStream | |
MergeStream |
Unions streamA with streamB ordering the Tuples based on a Comparator.
|
MultiComp |
Wraps multiple Comparators to provide sub-sorting.
|
ParallelStream |
The ParallelStream decorates a TupleStream implementation and pushes it to N workers for parallel execution.
|
PushBackStream |
A TupleStream that allows a single Tuple to be pushed back onto the stream after it's been read.
|
RankStream |
Iterates over a TupleStream and Ranks the topN tuples based on a Comparator.
|
ReducerStream |
Iterates over a TupleStream and buffers Tuples that are equal based on a comparator.
|
SolrClientCache |
The SolrClientCache caches SolrClients so they can be reused by different TupleStreams.
|
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.
|
Tuple |
A simple abstraction of a record containing key/value pairs.
|
TupleStream | |
UniqueStream |
The UniqueStream emits a unique stream of Tuples based on a Comparator.
|
Copyright © 2000-2015 Apache Software Foundation. All Rights Reserved.