public class SelectExprProcessorEvalStreamInsertTable extends Object implements ExprForge, ExprEvaluator, ExprNodeRenderable
Constructor and Description |
---|
SelectExprProcessorEvalStreamInsertTable(int streamNum,
ExprStreamUnderlyingNode undNode,
TableMetadata tableMetadata,
Class returnType) |
Modifier and Type | Method and Description |
---|---|
static EventBean |
convertToTableEvent(int streamNum,
TableMetadataInternalEventToPublic eventToPublic,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
Object |
evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Evaluate event tuple and return result.
|
CodegenExpression |
evaluateCodegen(CodegenParamSetExprPremade params,
CodegenContext context) |
ExprForgeComplexityEnum |
getComplexity() |
Class |
getEvaluationType() |
ExprEvaluator |
getExprEvaluator() |
ExprNodeRenderable |
getForgeRenderable() |
void |
toEPL(StringWriter writer,
ExprPrecedenceEnum parentPrecedence) |
public SelectExprProcessorEvalStreamInsertTable(int streamNum, ExprStreamUnderlyingNode undNode, TableMetadata tableMetadata, Class returnType)
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 CodegenExpression evaluateCodegen(CodegenParamSetExprPremade params, CodegenContext context)
evaluateCodegen
in interface ExprForge
public ExprForgeComplexityEnum getComplexity()
getComplexity
in interface ExprForge
public static EventBean convertToTableEvent(int streamNum, TableMetadataInternalEventToPublic eventToPublic, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
streamNum
- stream numeventToPublic
- conversioneventsPerStream
- eventsisNewData
- flagexprEvaluatorContext
- contextpublic ExprEvaluator getExprEvaluator()
getExprEvaluator
in interface ExprForge
public Class getEvaluationType()
getEvaluationType
in interface ExprForge
public ExprNodeRenderable getForgeRenderable()
getForgeRenderable
in interface ExprForge
public void toEPL(StringWriter writer, ExprPrecedenceEnum parentPrecedence)
toEPL
in interface ExprNodeRenderable