public class SelectExprProcessorEvalStreamInsertNamedWindow extends Object implements ExprEvaluator
Constructor and Description |
---|
SelectExprProcessorEvalStreamInsertNamedWindow(int streamNum,
EventType namedWindowAsType,
Class returnType,
EventAdapterService eventAdapterService) |
Modifier and Type | Method and Description |
---|---|
Object |
evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Evaluate event tuple and return result.
|
int |
getStreamNum() |
Class |
getType()
Returns the type that the node's evaluate method returns an instance of.
|
public SelectExprProcessorEvalStreamInsertNamedWindow(int streamNum, EventType namedWindowAsType, Class returnType, EventAdapterService eventAdapterService)
public Object evaluate(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
ExprEvaluator
evaluate
in interface ExprEvaluator
eventsPerStream
- - event tupleisNewData
- - indicates whether we are dealing with new data (istream) or old data (rstream)exprEvaluatorContext
- context for expression evaluationpublic Class getType()
ExprEvaluator
getType
in interface ExprEvaluator
public int getStreamNum()