JavaScript is disabled on your browser.
Skip navigation links
Overview
Package
Class
Use
Tree
Deprecated
Index
Help
All Classes
SEARCH:
JavaScript is disabled on your browser.
All Classes
All Classes
Interface Summary
Class Summary
Enum Summary
Exception Summary
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
FeaturesSelectionStream.FeaturesSelectionCall
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
SignificantTermsStream.SignificantTermsCall
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
StreamExecutorHelper
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.LogitCall
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