public abstract class EvalSelectStreamBaseMap extends EvalSelectStreamBase implements SelectExprProcessorForge, SelectExprProcessor
context, evaluators, isUsingWildcard, namedStreams, resultEventType
Modifier | Constructor and Description |
---|---|
protected |
EvalSelectStreamBaseMap(SelectExprForgeContext selectExprForgeContext,
EventType resultEventType,
java.util.List<SelectClauseStreamCompiledSpec> namedStreams,
boolean usingWildcard) |
Modifier and Type | Method and Description |
---|---|
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,
ExprEvaluatorContext exprEvaluatorContext) |
protected abstract CodegenExpression |
processSpecificCodegen(CodegenMember memberResultEventType,
CodegenMember memberEventAdapterService,
CodegenExpression props,
CodegenMethodScope codegenMethodScope,
ExprForgeCodegenSymbol exprSymbol,
CodegenClassScope codegenClassScope) |
getContext, getResultEventType, getSelectExprProcessor
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getResultEventType, getSelectExprProcessor
protected EvalSelectStreamBaseMap(SelectExprForgeContext selectExprForgeContext, EventType resultEventType, java.util.List<SelectClauseStreamCompiledSpec> namedStreams, boolean usingWildcard)
protected abstract EventBean processSpecific(java.util.Map<java.lang.String,java.lang.Object> props, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
protected abstract CodegenExpression processSpecificCodegen(CodegenMember memberResultEventType, CodegenMember memberEventAdapterService, CodegenExpression props, CodegenMethodScope codegenMethodScope, 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