public abstract class ExprTableEvalStrategyGroupByAccessBase extends ExprTableEvalStrategyGroupByBase implements ExprTableAccessEvalStrategy
Modifier | Constructor and Description |
---|---|
protected |
ExprTableEvalStrategyGroupByAccessBase(TableAndLockProviderGrouped provider,
AggregationAccessorSlotPair pair) |
Modifier and Type | Method and Description |
---|---|
protected EventBean |
evaluateGetEventBeanInternal(Object group,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
protected Collection<EventBean> |
evaluateGetROCollectionEventsInternal(Object group,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
protected Collection |
evaluateGetROCollectionScalarInternal(Object group,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
protected Object |
evaluateInternal(Object group,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object[] |
evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
lockTableRead, lockTableReadAndGet
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
evaluate, evaluateGetEventBean, evaluateGetROCollectionEvents, evaluateGetROCollectionScalar
protected ExprTableEvalStrategyGroupByAccessBase(TableAndLockProviderGrouped provider, AggregationAccessorSlotPair pair)
protected Object evaluateInternal(Object group, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
public Object[] evaluateTypableSingle(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
evaluateTypableSingle
in interface ExprTableAccessEvalStrategy
protected Collection<EventBean> evaluateGetROCollectionEventsInternal(Object group, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
protected EventBean evaluateGetEventBeanInternal(Object group, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
protected Collection evaluateGetROCollectionScalarInternal(Object group, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)