Package | Description |
---|---|
com.espertech.esper.epl.agg.service |
Aggregation services.
|
com.espertech.esper.epl.agg.util |
Aggregation utility classes centered around local group-by parameters.
|
Modifier and Type | Method and Description |
---|---|
static void |
AggSvcGroupLocalGroupByBase.aggregateIntoEnter(AggregationLocalGroupByLevel level,
AggregationMethod[] methods,
AggregationState[] states,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
static void |
AggSvcGroupLocalGroupByBase.aggregateIntoLeave(AggregationLocalGroupByLevel level,
AggregationMethod[] methods,
AggregationState[] states,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
protected abstract Object |
AggSvcGroupLocalGroupByBase.computeGroupKey(AggregationLocalGroupByLevel level,
Object groupKey,
ExprEvaluator[] partitionEval,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
protected Object |
AggSvcGroupByLocalGroupBy.computeGroupKey(AggregationLocalGroupByLevel level,
Object groupKey,
ExprEvaluator[] partitionEval,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
protected Object |
AggSvcGroupAllLocalGroupBy.computeGroupKey(AggregationLocalGroupByLevel level,
Object groupKey,
ExprEvaluator[] partitionEval,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Modifier and Type | Method and Description |
---|---|
AggregationLocalGroupByLevel[] |
AggregationLocalGroupByPlan.getAllLevels() |
AggregationLocalGroupByLevel |
AggregationLocalGroupByPlan.getOptionalLevelTop() |
Constructor and Description |
---|
AggregationLocalGroupByPlan(int numMethods,
int numAccess,
AggregationLocalGroupByColumn[] columns,
AggregationLocalGroupByLevel optionalLevelTop,
AggregationLocalGroupByLevel[] allLevels) |
AggregationLocalGroupByPlan(int numMethods,
int numAccess,
AggregationLocalGroupByColumn[] columns,
AggregationLocalGroupByLevel optionalLevelTop,
AggregationLocalGroupByLevel[] allLevels) |