com.espertech.esper.epl.core.eval
Class EvalSelectStreamBaseMap

java.lang.Object
  com.espertech.esper.epl.core.eval.EvalSelectStreamBase
      com.espertech.esper.epl.core.eval.EvalSelectStreamBaseMap

All Implemented Interfaces:

SelectExprProcessor

Direct Known Subclasses:

EvalSelectStreamNoUnderlyingMap, EvalSelectStreamNoUndWEventBeanToObj, EvalSelectStreamWUnderlying

public abstract class EvalSelectStreamBaseMap
extends EvalSelectStreamBase
implements SelectExprProcessor

Field Summary

Fields inherited from class com.espertech.esper.epl.core.eval.EvalSelectStreamBase

isUsingWildcard, namedStreams, resultEventType, selectExprContext

Constructor Summary

protected

EvalSelectStreamBaseMap(SelectExprContext selectExprContext, EventType resultEventType, java.util.List<SelectClauseStreamCompiledSpec> namedStreams, boolean usingWildcard)

Method Summary

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(java.util.Map<java.lang.String,java.lang.Object> props, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)

Methods inherited from class com.espertech.esper.epl.core.eval.EvalSelectStreamBase

getResultEventType, getSelectExprContext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.espertech.esper.epl.core.SelectExprProcessor

getResultEventType

Constructor Detail

EvalSelectStreamBaseMap

protected EvalSelectStreamBaseMap(SelectExprContext selectExprContext,
                                  EventType resultEventType,
                                  java.util.List<SelectClauseStreamCompiledSpec> namedStreams,
                                  boolean usingWildcard)

Method Detail

processSpecific

public abstract EventBean processSpecific(java.util.Map<java.lang.String,java.lang.Object> props,
                                          EventBean[] eventsPerStream,
                                          boolean isNewData,
                                          ExprEvaluatorContext exprEvaluatorContext)

process

public EventBean process(EventBean[] eventsPerStream,
                         boolean isNewData,
                         boolean isSynthesize,
                         ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: SelectExprProcessor

Computes the select-clause results and returns an event of the result event type that contains, in it's properties, the selected items.

Specified by:

process in interface SelectExprProcessor

Parameters:

eventsPerStream - - is per stream the event

isNewData - - 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 set

Returns:

event with properties containing selected items