All Classes

Class	Description
AbsoluteValueEvaluator
AddEvaluator
AkimaEvaluator
AndEvaluator
AnovaEvaluator
AppendEvaluator
ArcCosineEvaluator
ArcSineEvaluator
ArcTangentEvaluator
ArrayEvaluator
AscEvaluator
Attributes
BetaDistributionEvaluator
BicubicSplineEvaluator
BiJoinStream	Joins leftStream with rightStream based on a Equalitor.
BinomialCoefficientEvaluator
BinomialDistributionEvaluator
Bucket
CalculatorStream
CanberraEvaluator
CartesianProductStream
CeilingEvaluator
CellStream
ChebyshevDistanceEvaluator
ChebyshevEvaluator
ChiSquareDataSetEvaluator
ClassificationEvaluation
CloudSolrStream	Connects to Zookeeper to pick replicas from a specific collection to send the query to.
CoalesceEvaluator
ColumnAtEvaluator
ColumnCountEvaluator
ColumnEvaluator
CommitStream	Sends a commit message to a SolrCloud collection
ComparatorLambda	Interface for use with a comparator lambda
ComparatorOrder	Enum for supported comparator ordering
ComplementStream	Emits tuples from streamA which do not exist in streamB.
ConcatEvaluator
ConcatOperation	Concatenates fields and adds them to the tuple.
ConstantDistributionEvaluator
ConversionEvaluator
ConvexHullEvaluator
ConvolutionEvaluator
CopyOfEvaluator
CopyOfRangeEvaluator
CorrelationEvaluator
CorrelationEvaluator.CorrelationType
CorrelationSignificanceEvaluator
CosineDistanceEvaluator
CosineDistanceEvaluator.CosineDistance
CosineEvaluator
CosineSimilarityEvaluator
CountDistinctMetric
CountMetric
CovarianceEvaluator
CsvStream
CubedRootEvaluator
CumulativeProbabilityEvaluator
DaemonStream
DateEvaluator
DbscanEvaluator
DbscanEvaluator.ClusterPoint
DbscanEvaluator.ClusterTuple
DeepRandomStream	Connects to Zookeeper to pick replicas from a specific collection to send the query to.
DefaultStreamFactory	A default collection of mappings, used to convert strings into stream expressions.
DeleteStream	Uses tuples to identify the uniqueKey values of documents to be deleted
DensityEvaluator
DerivativeEvaluator
DescribeEvaluator
DistanceEvaluator
DistanceEvaluator.DistanceType
DistinctOperation
DivideEvaluator
DotProductEvaluator
DoubleEvaluator
DrillStream
DriverImpl	Get a Connection with with a url and properties.
EarthMoversEvaluator
EBEAddEvaluator
EBEDivideEvaluator
EBEMultiplyEvaluator
EBESubtractEvaluator
EchoStream
EmpiricalDistributionEvaluator
EnclosingDiskEvaluator
EnumeratedDistributionEvaluator
Equalitor<T>	Interface defining a way to determine if two items are equal
EqualToEvaluator
EuclideanDistanceEvaluator
EuclideanEvaluator
EvalStream
EvaluatorException
ExceptionStream
ExclusiveOrEvaluator
ExecutorStream	The executor function wraps a stream with Tuples containing Streaming Expressions and executes them in parallel.
ExecutorStream.StreamTask
Explanation	Explanation containing details about a expression
Explanation.ExpressionType
ExponentialMovingAverageEvaluator
Expressible	Defines a stream that can be expressed in an expression
Facet2DStream
FacetStream	The FacetStream abstracts the output from the JSON facet API as a Stream of Tuples.
FactorialEvaluator
FeatureSelectEvaluator
FeaturesSelectionStream
FetchStream	Iterates over a stream and fetches additional fields from a specified collection.
FFTEvaluator
FieldComparator	An equality field Comparator which compares a field of two Tuples and determines sort order.
FieldEqualitor	An equality field Equalitor which compares a field of two Tuples and determines if they are equal.
FieldValueEvaluator
FindDelayEvaluator
FloorEvaluator
FrequencyTableEvaluator
FuzzyKmeansEvaluator
GammaDistributionEvaluator
GatherNodesStream
GaussFitEvaluator
GeometricDistributionEvaluator
GetAmplitudeEvaluator
GetAngularFrequencyEvaluator
GetAreaEvaluator
GetAttributeEvaluator
GetAttributesEvaluator
GetBaryCenterEvaluator
GetBoundarySizeEvaluator
GetCacheEvaluator
GetCenterEvaluator
GetCentroidsEvaluator
GetClusterEvaluator
GetColumnLabelsEvaluator
GetMembershipMatrixEvaluator
GetPhaseEvaluator
GetRadiusEvaluator
GetRowLabelsEvaluator
GetStream
GetSupportPointsEvaluator
GetValueEvaluator
GetVerticesEvaluator
GrandSumEvaluator
GreaterThanEqualToEvaluator
GreaterThanEvaluator
GroupOperation
GTestDataSetEvaluator
HarmonicFitEvaluator
HashJoinStream	Takes two streams (fullStream and hashStream) and joins them similar to an InnerJoinStream.
HashKey
HashRollupStream
HavingStream	The HavingStream iterates over an internal stream and applies a BooleanOperation to each tuple.
HistogramEvaluator
HyperbolicCosineEvaluator
HyperbolicSineEvaluator
HyperbolicTangentEvaluator
IFFTEvaluator
IfThenElseEvaluator
IndexOfEvaluator
InjectionDefense	A class with which to safely build a streaming expression.
InnerJoinStream	Joins leftStream with rightStream based on a Equalitor.
IntegrateEvaluator
IntersectStream	Emits tuples from streamA which also exist in streamB.
IsNullEvaluator
JavabinTupleStreamParser
JDBCStream	Connects to a datasource using a registered JDBC driver and execute a query.
JDBCStream.ResultSetValueSelector
JoinStream	Defines a JoinStream which can hold N streams, all joined with the same equalitor
JSONTupleStream
KmeansEvaluator
KmeansEvaluator.ClusterPoint
KmeansEvaluator.ClusterTuple
KnnEvaluator
KnnEvaluator.Neighbor
KnnRegressionEvaluator
KnnRegressionEvaluator.KnnRegressionTuple
KnnStream
KolmogorovSmirnovEvaluator
L1NormEvaluator
Lang
Lang.LocalInputStream
LatLonVectorsEvaluator	The LatLonVectorsEvaluator maps to the latlonVectors Math Expression.
LeftOuterJoinStream	Joins leftStream with rightStream based on a Equalitor.
LeftShiftEvaluator
LengthEvaluator
LerpEvaluator
LessThanEqualToEvaluator
LessThanEvaluator
LetStream
LInfNormEvaluator
ListCacheEvaluator
ListStream
LoessEvaluator
LoessEvaluator.LoessRegressionTuple
Log10Evaluator
LogNormalDistributionEvaluator
LongEvaluator
LowerEvaluator
ManhattanEvaluator
MannWhitneyUEvaluator
ManyValueWorker
MarkovChainEvaluator
MarkovChainEvaluator.MarkovChain
MatchesEvaluator
Matrix
MatrixEvaluator
MatrixMultiplyEvaluator
MaxMetric
MeanDifferenceEvaluator
MeanEvaluator
MeanMetric
MemsetEvaluator	The MemsetEvaluator reads a TupleStream and copies the values from specific fields into arrays that are bound to variable names in a map.
MergeStream	Merges two or more streams together ordering the Tuples based on a Comparator.
Metric
MinMaxScaleEvaluator
MinMetric
ModeEvaluator
ModelCache	The Model cache keeps a local in-memory copy of models
ModelStream	The ModelStream retrieves a stored model from a Solr Cloud collection.
ModuloEvaluator
MonteCarloEvaluator
MovingAverageEvaluator
MovingMADEvaluator
MovingMedianEvaluator
MultiKmeansEvaluator
MultipleFieldComparator	Wraps multiple Comparators to provide sub-sorting.
MultipleFieldEqualitor	Wraps multiple Equalitors.
MultiplyEvaluator
MultiVariateNormalDistributionEvaluator
NaturalEvaluator
NaturalLogEvaluator
Node
NoOpStream	A simple no-operation stream.
NormalDistributionEvaluator
NormalizeEvaluator
NormalizeSumEvaluator
NormEvaluator
NotEvaluator
NotNullEvaluator
NullStream	The NullStream Iterates over a TupleStream and eats the tuples.
OLSRegressionEvaluator
OLSRegressionEvaluator.MultipleRegressionTuple
OnesEvaluator
OneValueWorker
OrEvaluator
OscillateEvaluator
OuterHashJoinStream	Takes two streams (fullStream and hashStream) and joins them similar to an LeftOuterJoinStream.
OutliersEvaluator
PairedTTestEvaluator
PairSortEvaluator
ParallelListStream
ParallelListStream.StreamIndex
ParallelListStream.StreamOpener
ParallelMetricsRollup	Indicates the underlying stream source supports parallelizing metrics computation across collections using a rollup of metrics from each collection.
ParallelStream	The ParallelStream decorates a TupleStream implementation and pushes it to N workers for parallel execution.
PercentileEvaluator
PercentileMetric
PivotEvaluator
PlotStream
PoissonDistributionEvaluator
PolyFitDerivativeEvaluator
PolyFitEvaluator
PowerEvaluator
PrecisionEvaluator
PredictEvaluator
PrimesEvaluator
PriorityStream	The priority function wraps two topics that represent high priority and low priority task queues.
ProbabilityEvaluator
ProjectToBorderEvaluator
PushBackStream	A TupleStream that allows a single Tuple to be pushed back onto the stream after it's been read.
PutCacheEvaluator
RandomFacadeStream
RandomStream	The RandomStream emits a stream of pseudo random Tuples that match the query parameters.
RankEvaluator
RankStream	Iterates over a TupleStream and Ranks the topN tuples based on a Comparator.
RawValueEvaluator
RecipEvaluator
RecNumEvaluator
RecursiveBooleanEvaluator
RecursiveBooleanEvaluator.BooleanChecker
RecursiveBooleanEvaluator.Checker
RecursiveBooleanEvaluator.NullChecker
RecursiveBooleanEvaluator.NumberChecker
RecursiveBooleanEvaluator.StringChecker
RecursiveEvaluator
RecursiveNumericEvaluator
RecursiveNumericListEvaluator
RecursiveObjectEvaluator
RecursiveTemporalEvaluator
ReduceOperation
ReducerStream	Iterates over a TupleStream and buffers Tuples that are equal based on a comparator.
RegressionEvaluator
RegressionEvaluator.RegressionTuple
RemoveCacheEvaluator
RepeatEvaluator
ReplaceOperation	Replaces some tuple value with another.
ReplaceWithFieldOperation	Implementation of replace(...., withField=fieldName) See ReplaceOperation for description.
ReplaceWithValueOperation	Implementation of replace(...., withValue="some value") See ReplaceOperation for description.
ReverseEvaluator
RightShiftEvaluator
RollupStream
RoundEvaluator
RowAtEvaluator
RowCountEvaluator
SampleEvaluator
ScalarAddEvaluator
ScalarDivideEvaluator
ScalarMultiplyEvaluator
ScalarSubtractEvaluator
ScaleEvaluator
ScoreNodesStream	Iterates over a gatherNodes() expression and scores the Tuples based on tf-idf.
SearchFacadeStream	Connects to Zookeeper to pick replicas from a specific collection to send the query to.
SearchStream
SelectStream	Selects fields from the incoming stream and applies optional field renaming.
SequenceEvaluator
SetColumnLabelsEvaluator
SetRowLabelsEvaluator
SetValueEvaluator
ShortestPathStream
ShuffleStream
SignificantTermsStream
SineEvaluator
SingleValueComparator	An equality Comparator to be used when a stream will only ever return a single field, ie, it has no sorted order
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.
SolrStream.HandledException
SortStream	The SortStream emits a stream of Tuples sorted by a Comparator.
SourceEvaluator
SplineEvaluator
SplitEvaluator
SqlStream
SquareRootEvaluator
StandardDeviationEvaluator
StatsStream
StdMetric
StreamComparator	Defines a comparator we can use with TupleStreams
StreamContext	The StreamContext is passed to TupleStreams using the TupleStream.setStreamContext() method.
StreamEqualitor	Defines a comparator we can use with TupleStreams
StreamEvaluator
StreamEvaluatorException
StreamExplanation	Explanation containing details about a stream expression
StreamExpression	Expression containing a function and set of parameters
StreamExpressionNamedParameter	Provides a named parameter
StreamExpressionParameter	Base interface of a stream parameter
StreamExpressionParser	Takes a prefix notation expression and returns a tokenized expression
StreamExpressionValue	Basic string stream expression
StreamFactory	Used to convert strings into stream expressions
StreamOperation	Interface for any operation one can perform on a tuple in a TupleStream
SubtractEvaluator
SumColumnsEvaluator
SumDifferenceEvaluator
SumMetric
SumRowsEvaluator
SumSqEvaluator
TangentEvaluator
TemporalEvaluatorDay	Provides a day stream evaluator
TemporalEvaluatorDayOfQuarter	Provides a day stream evaluator
TemporalEvaluatorDayOfYear	Provides a day stream evaluator
TemporalEvaluatorEpoch	Provides a day stream evaluator
TemporalEvaluatorHour	Provides a day stream evaluator
TemporalEvaluatorMinute	Provides a day stream evaluator
TemporalEvaluatorMonth	Provides a day stream evaluator
TemporalEvaluatorQuarter	Provides a day stream evaluator
TemporalEvaluatorSecond	Provides a day stream evaluator
TemporalEvaluatorWeek	Provides a day stream evaluator
TemporalEvaluatorYear	Provides a day stream evaluator
TermVectorsEvaluator
TextLogitStream
TextLogitStream.TermsStream
TimeDifferencingEvaluator
TimeSeriesStream
TopFeaturesEvaluator
TopFeaturesEvaluator.Pair
TopicStream
TransposeEvaluator
Traversal
Traversal.Scatter
TriangularDistributionEvaluator
TrimEvaluator
TruncEvaluator
TsvStream
TTestEvaluator
Tuple	A simple abstraction of a record containing key/value pairs.
TupleStream
TupleStream.IgnoreException
TupleStreamParser
TupStream
TwoValueWorker
UniformDistributionEvaluator
UniformIntegerDistributionEvaluator
UniqueStream	The UniqueStream emits a unique stream of Tuples based on a Comparator.
UnitEvaluator
UpdateStream	Sends tuples emitted by a wrapped TupleStream as updates to a SolrCloud collection.
UpperEvaluator
UuidEvaluator
ValueAtEvaluator
ValueWorker
VarianceEvaluator
VectorFunction
WeibullDistributionEvaluator
WeightedSumMetric
ZerosEvaluator
ZipFDistributionEvaluator
ZplotStream