org.apache.solr.client.solrj.io.eval

Interface StreamEvaluator

All Superinterfaces:

Expressible, Serializable

All Known Implementing Classes:

AbsoluteValueEvaluator, AddEvaluator, AndEvaluator, AnovaEvaluator, AppendEvaluator, ArcCosineEvaluator, ArcSineEvaluator, ArcTangentEvaluator, ArrayEvaluator, AscEvaluator, BetaDistributionEvaluator, BinomialCoefficientEvaluator, BinomialDistributionEvaluator, CeilingEvaluator, ChebyshevDistanceEvaluator, CoalesceEvaluator, ColumnEvaluator, ConstantDistributionEvaluator, ConversionEvaluator, ConvolutionEvaluator, CopyOfEvaluator, CopyOfRangeEvaluator, CorrelationEvaluator, CorrelationSignificanceEvaluator, CosineEvaluator, CosineSimilarityEvaluator, CovarianceEvaluator, CubedRootEvaluator, CumulativeProbabilityEvaluator, DerivativeEvaluator, DescribeEvaluator, DistanceEvaluator, DivideEvaluator, DotProductEvaluator, EBEAddEvaluator, EBEDivideEvaluator, EBEMultiplyEvaluator, EBESubtractEvaluator, EmpiricalDistributionEvaluator, EnumeratedDistributionEvaluator, EqualToEvaluator, EuclideanDistanceEvaluator, ExclusiveOrEvaluator, ExponentialMovingAverageEvaluator, FactorialEvaluator, FieldValueEvaluator, FindDelayEvaluator, FloorEvaluator, FrequencyTableEvaluator, GammaDistributionEvaluator, GeometricDistributionEvaluator, GrandSumEvaluator, GreaterThanEqualToEvaluator, GreaterThanEvaluator, HarmonicFitEvaluator, HistogramEvaluator, HyperbolicCosineEvaluator, HyperbolicSineEvaluator, HyperbolicTangentEvaluator, IfThenElseEvaluator, KolmogorovSmirnovEvaluator, LengthEvaluator, LessThanEqualToEvaluator, LessThanEvaluator, LoessEvaluator, LogNormalDistributionEvaluator, MarkovChainEvaluator, MatrixEvaluator, MeanDifferenceEvaluator, MeanEvaluator, MinMaxScaleEvaluator, ModeEvaluator, ModuloEvaluator, MonteCarloEvaluator, MovingAverageEvaluator, MovingMedianEvaluator, MultiplyEvaluator, NaturalLogEvaluator, NormalDistributionEvaluator, NormalizeEvaluator, NormalizeSumEvaluator, NotEvaluator, OLSRegressionEvaluator, OrEvaluator, PercentileEvaluator, PoissonDistributionEvaluator, PolyFitDerivativeEvaluator, PolyFitEvaluator, PowerEvaluator, PrecisionEvaluator, PredictEvaluator, PrimesEvaluator, ProbabilityEvaluator, RankEvaluator, RawValueEvaluator, RecursiveBooleanEvaluator, RecursiveEvaluator, RecursiveNumericEvaluator, RecursiveNumericListEvaluator, RecursiveObjectEvaluator, RecursiveTemporalEvaluator, RegressionEvaluator, ReverseEvaluator, RoundEvaluator, SampleEvaluator, ScalarAddEvaluator, ScalarDivideEvaluator, ScalarMultiplyEvaluator, ScalarSubtractEvaluator, ScaleEvaluator, SequenceEvaluator, SineEvaluator, SourceEvaluator, SplineEvaluator, SquareRootEvaluator, SubtractEvaluator, SumColumnsEvaluator, SumDifferenceEvaluator, SumRowsEvaluator, TangentEvaluator, TemporalEvaluatorDay, TemporalEvaluatorDayOfQuarter, TemporalEvaluatorDayOfYear, TemporalEvaluatorEpoch, TemporalEvaluatorHour, TemporalEvaluatorMinute, TemporalEvaluatorMonth, TemporalEvaluatorQuarter, TemporalEvaluatorSecond, TemporalEvaluatorWeek, TemporalEvaluatorYear, TimeDifferencingEvaluator, TransposeEvaluator, TriangularDistributionEvaluator, UniformDistributionEvaluator, UniformIntegerDistributionEvaluator, UnitEvaluator, UuidEvaluator, WeibullDistributionEvaluator, ZipFDistributionEvaluator

public interface StreamEvaluator
extends Expressible, Serializable

Method Summary

Modifier and Type	Method and Description
Object	evaluate(Tuple tuple)
default Object	evaluateOverContext() Execute the evaluator over lets stored within the StreamContext.
StreamContext	getStreamContext()
void	setStreamContext(StreamContext streamContext)

Methods inherited from interface org.apache.solr.client.solrj.io.stream.expr.Expressible

toExplanation, toExpression

Method Detail

setStreamContext

void setStreamContext(StreamContext streamContext)

getStreamContext

StreamContext getStreamContext()

evaluate

Object evaluate(Tuple tuple)
         throws IOException

Throws:

IOException

evaluateOverContext

default Object evaluateOverContext()
                            throws IOException

Execute the evaluator over lets stored within the StreamContext. This allows evaluators to be executed over values calculated elsewhere in the pipeline and stored in the streamContext.lets Default implementation just creates a tuple out of all values in the context and passes that to evaluate(Tuple).

Returns:

Evaluated value

Throws:

IOException - throw on error during evaluation