public class EvalSelectStreamWUnderlying extends EvalSelectStreamBaseMap implements SelectExprProcessor
isUsingWildcard, namedStreams, resultEventType, selectExprContext
Constructor and Description |
---|
EvalSelectStreamWUnderlying(SelectExprContext selectExprContext,
EventType resultEventType,
List<SelectClauseStreamCompiledSpec> namedStreams,
boolean usingWildcard,
List<SelectExprStreamDesc> unnamedStreams,
boolean singleStreamWrapper,
boolean underlyingIsFragmentEvent,
int underlyingStreamNumber,
EventPropertyGetter underlyingPropertyEventGetter,
ExprEvaluator underlyingExprEvaluator,
TableMetadata tableMetadata) |
Modifier and Type | Method and Description |
---|---|
EventBean |
processSpecific(Map<String,Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
process
getResultEventType, getSelectExprContext
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getResultEventType, process
public EvalSelectStreamWUnderlying(SelectExprContext selectExprContext, EventType resultEventType, List<SelectClauseStreamCompiledSpec> namedStreams, boolean usingWildcard, List<SelectExprStreamDesc> unnamedStreams, boolean singleStreamWrapper, boolean underlyingIsFragmentEvent, int underlyingStreamNumber, EventPropertyGetter underlyingPropertyEventGetter, ExprEvaluator underlyingExprEvaluator, TableMetadata tableMetadata)
public EventBean processSpecific(Map<String,Object> props, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
processSpecific
in class EvalSelectStreamBaseMap