public abstract class EvalBaseMap extends EvalBase implements SelectExprProcessor, SelectExprProcessorForge
Modifier and Type | Field and Description |
---|---|
protected ExprEvaluator[] |
evaluators |
context, resultEventType
Modifier | Constructor and Description |
---|---|
protected |
EvalBaseMap(SelectExprForgeContext selectExprForgeContext,
EventType resultEventType) |
Modifier and Type | Method and Description |
---|---|
SelectExprProcessor |
getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
protected abstract void |
initSelectExprProcessorSpecific(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
EventBean |
process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
Computes the select-clause results and returns an event of the result event type that contains, in it's
properties, the selected items.
|
CodegenMethodNode |
processCodegen(CodegenMember memberResultEventType,
CodegenMember memberEventAdapterService,
CodegenMethodScope codegenMethodScope,
SelectExprProcessorCodegenSymbol selectSymbol,
ExprForgeCodegenSymbol exprSymbol,
CodegenClassScope codegenClassScope) |
protected abstract EventBean |
processSpecific(java.util.Map<java.lang.String,java.lang.Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
protected abstract CodegenExpression |
processSpecificCodegen(CodegenMember memberResultEventType,
CodegenMember memberEventAdapterService,
CodegenExpression props,
CodegenMethodNode methodNode,
SelectExprProcessorCodegenSymbol selectEnv,
ExprForgeCodegenSymbol exprSymbol,
CodegenClassScope codegenClassScope) |
getEventAdapterService, getResultEventType
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getResultEventType
protected ExprEvaluator[] evaluators
protected EvalBaseMap(SelectExprForgeContext selectExprForgeContext, EventType resultEventType)
protected abstract void initSelectExprProcessorSpecific(EngineImportService engineImportService, boolean isFireAndForget, java.lang.String statementName)
protected abstract EventBean processSpecific(java.util.Map<java.lang.String,java.lang.Object> props, EventBean[] eventsPerStream, boolean isNewData, boolean isSynthesize, ExprEvaluatorContext exprEvaluatorContext)
protected abstract CodegenExpression processSpecificCodegen(CodegenMember memberResultEventType, CodegenMember memberEventAdapterService, CodegenExpression props, CodegenMethodNode methodNode, SelectExprProcessorCodegenSymbol selectEnv, ExprForgeCodegenSymbol exprSymbol, CodegenClassScope codegenClassScope)
public EventBean process(EventBean[] eventsPerStream, boolean isNewData, boolean isSynthesize, ExprEvaluatorContext exprEvaluatorContext)
SelectExprProcessor
process
in interface SelectExprProcessor
eventsPerStream
- - is per stream the eventisNewData
- - indicates whether we are dealing with new data (istream) or old data (rstream)isSynthesize
- - set to true to indicate that synthetic events are required for an iterator result setexprEvaluatorContext
- contextpublic CodegenMethodNode processCodegen(CodegenMember memberResultEventType, CodegenMember memberEventAdapterService, CodegenMethodScope codegenMethodScope, SelectExprProcessorCodegenSymbol selectSymbol, ExprForgeCodegenSymbol exprSymbol, CodegenClassScope codegenClassScope)
processCodegen
in interface SelectExprProcessorForge
public SelectExprProcessor getSelectExprProcessor(EngineImportService engineImportService, boolean isFireAndForget, java.lang.String statementName)
getSelectExprProcessor
in interface SelectExprProcessorForge