Defines a stream that can be expressed in an expression
Connects to Zookeeper to pick replicas from a specific collection to send the query to.
Unions streamA with streamB ordering the Tuples based on a Comparator.
The ParallelStream decorates a TupleStream implementation and pushes it to N workers for parallel execution.
A TupleStream that allows a single Tuple to be pushed back onto the stream after it's been read.
Iterates over a TupleStream and Ranks the topN tuples based on a Comparator.
Iterates over a TupleStream and buffers Tuples that are equal based on a comparator.
Queries a single Solr instance and maps SolrDocs to a Stream of Tuples.
The StreamContext is passed to TupleStreams using the TupleStream.setStreamContext() method.
The UniqueStream emits a unique stream of Tuples based on a Comparator.
Copyright © 2000-2015 Apache Software Foundation. All Rights Reserved.