public abstract class EvalSelectStreamBaseMap extends EvalSelectStreamBase implements SelectExprProcessor
isUsingWildcard, namedStreams, resultEventType, selectExprContext
Modifier | Constructor and Description |
---|---|
protected |
EvalSelectStreamBaseMap(SelectExprContext selectExprContext,
EventType resultEventType,
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.
|
abstract EventBean |
processSpecific(Map<String,Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
getResultEventType, getSelectExprContext
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getResultEventType
protected EvalSelectStreamBaseMap(SelectExprContext selectExprContext, EventType resultEventType, List<SelectClauseStreamCompiledSpec> namedStreams, boolean usingWildcard)
public abstract EventBean processSpecific(Map<String,Object> props, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
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
- context