public class AggregationAccessorFirstWEval extends java.lang.Object implements AggregationAccessor
Constructor and Description |
---|
AggregationAccessorFirstWEval(int streamNum,
ExprEvaluator childNode)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
EventBean |
getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Return the aggregation state value consisting of a single event.
|
static void |
getEnumerableEventCodegen(AggregationAccessorFirstWEvalForge forge,
AggregationStateLinearForge stateForge,
AggregationAccessorForgeGetCodegenContext context) |
java.util.Collection<EventBean> |
getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Return the aggregation state value consisting of a collection of events.
|
static void |
getEnumerableEventsCodegen(AggregationAccessorFirstWEvalForge forge,
AggregationStateLinearForge stateForge,
AggregationAccessorForgeGetCodegenContext context) |
java.util.Collection<java.lang.Object> |
getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Return the aggregation state value consisting of a collection of scalar values.
|
static void |
getEnumerableScalarCodegen(AggregationAccessorFirstWEvalForge forge,
AggregationStateLinearForge accessStateFactory,
AggregationAccessorForgeGetCodegenContext context) |
java.lang.Object |
getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Return the aggregation state value either as a scalar value or any other object.
|
static void |
getValueCodegen(AggregationAccessorFirstWEvalForge forge,
AggregationStateLinearForge accessStateFactory,
AggregationAccessorForgeGetCodegenContext context) |
public AggregationAccessorFirstWEval(int streamNum, ExprEvaluator childNode)
streamNum
- stream idchildNode
- expressionpublic java.lang.Object getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
AggregationAccessor
For enumeration over scalar values or objects return an array or collection of scalar or object values.
Use the #getEnumerableEvents method to return a collection of events.
Use the #getEnumerableEvent to return a single events.
getValue
in interface AggregationAccessor
state
- aggregation state, downcast as neededeventsPerStream
- eventsisNewData
- new-data indicatorexprEvaluatorContext
- eval contextpublic static void getValueCodegen(AggregationAccessorFirstWEvalForge forge, AggregationStateLinearForge accessStateFactory, AggregationAccessorForgeGetCodegenContext context)
public java.util.Collection<EventBean> getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
AggregationAccessor
getEnumerableEvents
in interface AggregationAccessor
state
- aggregation state, downcast as neededeventsPerStream
- eventsisNewData
- new-data indicatorexprEvaluatorContext
- eval contextpublic static void getEnumerableEventsCodegen(AggregationAccessorFirstWEvalForge forge, AggregationStateLinearForge stateForge, AggregationAccessorForgeGetCodegenContext context)
public java.util.Collection<java.lang.Object> getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
AggregationAccessor
getEnumerableScalar
in interface AggregationAccessor
state
- aggregation state, downcast as neededeventsPerStream
- eventsisNewData
- new-data indicatorexprEvaluatorContext
- eval contextpublic static void getEnumerableScalarCodegen(AggregationAccessorFirstWEvalForge forge, AggregationStateLinearForge accessStateFactory, AggregationAccessorForgeGetCodegenContext context)
public EventBean getEnumerableEvent(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
AggregationAccessor
getEnumerableEvent
in interface AggregationAccessor
state
- aggregation state, downcast as neededeventsPerStream
- eventsisNewData
- new-data indicatorexprEvaluatorContext
- eval contextpublic static void getEnumerableEventCodegen(AggregationAccessorFirstWEvalForge forge, AggregationStateLinearForge stateForge, AggregationAccessorForgeGetCodegenContext context)