All Classes and Interfaces
Class
Description
Joins leftStream with rightStream based on an
StreamEqualitor.Connects to Zookeeper to pick replicas from a specific collection to send the query to.
Sends a commit message to a SolrCloud collection
Interface for use with a comparator lambda
Enum for supported comparator ordering
Emits tuples from streamA which do not exist in streamB.
Concatenates fields and adds them to the tuple.
Connects to Zookeeper to pick replicas from a specific collection to send the query to.
A default collection of mappings, used to convert strings into stream expressions.
Uses tuples to identify the uniqueKey values of documents to be deleted
Get a Connection with an url and properties.
Interface defining a way to determine if two items are equal
The executor function wraps a stream with Tuples containing Streaming Expressions and executes
them in parallel.
Explanation containing details about a expression
Defines a stream that can be expressed in an expression
The FacetStream abstracts the output from the JSON facet API as a Stream of Tuples.
Iterates over a stream and fetches additional fields from a specified collection.
An equality field Comparator which compares a field of two Tuples and determines sort order.
An equality field Equalitor which compares a field of two Tuples and determines if they are
equal.
Joins leftStream with rightStream based on an Equalitor.
Takes two streams (fullStream and hashStream) and joins them similar to an InnerJoinStream.
The HavingStream iterates over an internal stream and applies a BooleanOperation to each tuple.
A class with which to safely build a streaming expression.
Joins leftStream with rightStream based on an Equalitor.
Emits tuples from streamA which also exist in streamB.
Connects to a datasource using a registered JDBC driver and execute a query.
Defines a JoinStream which can hold N streams, all joined with the same equalitor
The LatLonVectorsEvaluator maps to the latlonVectors Math Expression.
Joins leftStream with rightStream based on an Equalitor.
The MemsetEvaluator reads a TupleStream and copies the values from specific fields into arrays
that are bound to variable names in a map.
Merges two or more streams together ordering the Tuples based on a Comparator.
The Model cache keeps a local in-memory copy of models
The ModelStream retrieves a stored model from a Solr Cloud collection.
Wraps multiple Comparators to provide sub-sorting.
Wraps multiple Equalitors.
A simple no-operation stream.
The NullStream Iterates over a TupleStream and eats the tuples.
Takes two streams (fullStream and hashStream) and joins them similar to an LeftOuterJoinStream.
Indicates the underlying stream source supports parallelizing metrics computation across
collections using a rollup of metrics from each collection.
The ParallelStream decorates a TupleStream implementation and pushes it to N workers for parallel
execution.
The priority function wraps two topics that represent high priority and low priority task queues.
A TupleStream that allows a single Tuple to be pushed back onto the stream after it's been read.
The RandomStream emits a stream of pseudo random Tuples that match the query parameters.
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.
Replaces some tuple value with another.
Implementation of replace(...., withField=fieldName) See ReplaceOperation for description.
Implementation of replace(...., withValue="some value") See ReplaceOperation for description.
Iterates over a gatherNodes() expression and scores the Tuples based on tf-idf.
Connects to Zookeeper to pick replicas from a specific collection to send the query to.
Selects fields from the incoming stream and applies optional field renaming.
An equality Comparator to be used when a stream will only ever return a single field, ie, it has
no sorted order
The SolrClientCache caches SolrClients, so they can be reused by different TupleStreams.
Queries a single Solr instance and maps SolrDocs to a Stream of Tuples.
The SortStream emits a stream of Tuples sorted by a Comparator.
Defines a comparator we can use with TupleStreams
The StreamContext is passed to TupleStreams using the TupleStream.setStreamContext() method.
Defines a comparator we can use with TupleStreams
Explanation containing details about a stream expression
Expression containing a function and set of parameters
Provides a named parameter
Base interface of a stream parameter
Takes a prefix notation expression and returns a tokenized expression
Basic string stream expression
Used to convert strings into stream expressions
Interface for any operation one can perform on a tuple in a TupleStream
Provides a day stream evaluator
Provides a day stream evaluator
Provides a day stream evaluator
Provides a day stream evaluator
Provides a day stream evaluator
Provides a day stream evaluator
Provides a day stream evaluator
Provides a day stream evaluator
Provides a day stream evaluator
Provides a day stream evaluator
Provides a day stream evaluator
A simple abstraction of a record containing key/value pairs.
The UniqueStream emits a unique stream of Tuples based on a Comparator.
Sends tuples emitted by a wrapped
TupleStream as updates to a SolrCloud collection.