class |
BiJoinStream |
Joins leftStream with rightStream based on a Equalitor.
|
class |
CalculatorStream |
|
class |
CartesianProductStream |
|
class |
CellStream |
|
class |
CloudSolrStream |
Connects to Zookeeper to pick replicas from a specific collection to send the query to.
|
class |
CommitStream |
Sends a commit message to a SolrCloud collection
|
class |
ComplementStream |
Emits tuples from streamA which do not exist in streamB.
|
class |
CsvStream |
|
class |
DaemonStream |
|
class |
DeepRandomStream |
Connects to Zookeeper to pick replicas from a specific collection to send the query to.
|
class |
DeleteStream |
Uses tuples to identify the uniqueKey values of documents to be deleted
|
class |
EchoStream |
|
class |
EvalStream |
|
class |
ExceptionStream |
|
class |
ExecutorStream |
The executor function wraps a stream with Tuples containing Streaming Expressions
and executes them in parallel.
|
class |
Facet2DStream |
|
class |
FacetStream |
The FacetStream abstracts the output from the JSON facet API as a Stream of Tuples.
|
class |
FeaturesSelectionStream |
|
class |
FetchStream |
Iterates over a stream and fetches additional fields from a specified collection.
|
class |
GetStream |
|
class |
HashJoinStream |
Takes two streams (fullStream and hashStream) and joins them similar to an InnerJoinStream.
|
class |
HashRollupStream |
|
class |
HavingStream |
The HavingStream iterates over an internal stream and applies a BooleanOperation to each tuple.
|
class |
InnerJoinStream |
Joins leftStream with rightStream based on a Equalitor.
|
class |
IntersectStream |
Emits tuples from streamA which also exist in streamB.
|
class |
JDBCStream |
Connects to a datasource using a registered JDBC driver and execute a query.
|
class |
JoinStream |
Defines a JoinStream which can hold N streams, all joined with the same equalitor
|
class |
KnnStream |
|
class |
LeftOuterJoinStream |
Joins leftStream with rightStream based on a Equalitor.
|
class |
LetStream |
|
class |
ListStream |
|
class |
MergeStream |
Merges two or more streams together ordering the Tuples based on a Comparator.
|
class |
ModelStream |
The ModelStream retrieves a stored model from a Solr Cloud collection.
|
class |
NoOpStream |
A simple no-operation stream.
|
class |
NullStream |
The NullStream Iterates over a TupleStream and eats the tuples.
|
class |
OuterHashJoinStream |
Takes two streams (fullStream and hashStream) and joins them similar to an LeftOuterJoinStream.
|
class |
ParallelListStream |
|
class |
ParallelStream |
The ParallelStream decorates a TupleStream implementation and pushes it to N workers for parallel execution.
|
class |
PlotStream |
|
class |
PriorityStream |
The priority function wraps two topics that represent high priority and low priority task queues.
|
class |
PushBackStream |
A TupleStream that allows a single Tuple to be pushed back onto the stream after it's been read.
|
class |
RandomFacadeStream |
|
class |
RandomStream |
The RandomStream emits a stream of psuedo random Tuples that match the query parameters.
|
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 |
RollupStream |
|
class |
ScoreNodesStream |
Iterates over a gatherNodes() expression and scores the Tuples based on tf-idf.
|
class |
SearchFacadeStream |
Connects to Zookeeper to pick replicas from a specific collection to send the query to.
|
class |
SearchStream |
|
class |
SelectStream |
Selects fields from the incoming stream and applies optional field renaming.
|
class |
ShuffleStream |
|
class |
SignificantTermsStream |
|
class |
SolrStream |
Queries a single Solr instance and maps SolrDocs to a Stream of Tuples.
|
class |
SortStream |
The SortStream emits a stream of Tuples sorted by a Comparator.
|
class |
SqlStream |
|
class |
StatsStream |
|
class |
TextLogitStream |
|
protected static class |
TextLogitStream.TermsStream |
|
class |
TimeSeriesStream |
|
class |
TopicStream |
|
class |
TsvStream |
|
class |
TupStream |
|
class |
UniqueStream |
The UniqueStream emits a unique stream of Tuples based on a Comparator.
|
class |
UpdateStream |
Sends tuples emitted by a wrapped TupleStream as updates to a SolrCloud collection.
|
class |
ZplotStream |
|