Class EvaluationCalc
- java.lang.Object
-
- org.apache.storm.sql.runtime.streams.functions.EvaluationCalc
-
- All Implemented Interfaces:
Serializable,FlatMapFunction<Values,Values>,Function<Values,Iterable<Values>>,Operation
public class EvaluationCalc extends Object implements FlatMapFunction<Values,Values>
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description EvaluationCalc(ExecutableExpression filterInstance, ExecutableExpression projectionInstance, int outputCount, org.apache.calcite.DataContext dataContext)EvaluationCalc Constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Iterable<Values>apply(Values input)Applies this function to the given argument.
-
-
-
Constructor Detail
-
EvaluationCalc
public EvaluationCalc(ExecutableExpression filterInstance, ExecutableExpression projectionInstance, int outputCount, org.apache.calcite.DataContext dataContext)
EvaluationCalc Constructor.- Parameters:
filterInstance- ExecutableExpressionprojectionInstance- ExecutableExpressionoutputCount- output countdataContext- DataContext
-
-