Package | Description |
---|---|
com.espertech.esper.epl.agg.service |
Aggregation services.
|
com.espertech.esper.epl.table.mgmt |
Table-related services and metadata.
|
com.espertech.esper.epl.table.strategy |
Table access evaluators.
|
Modifier and Type | Field and Description |
---|---|
protected Map<Object,AggregationRowPair> |
AggSvcGroupByMixedAccessImpl.aggregatorsPerGroup |
Modifier and Type | Method and Description |
---|---|
void |
AggSvcGroupByMixedAccessImpl.internalHandleUpdated(Object groupByKey,
AggregationRowPair groupAggregators) |
Modifier and Type | Method and Description |
---|---|
AggregationRowPair |
TableStateRowFactory.makeAggs(int agentInstanceId,
Object groupByKey,
Object groupKeyBinding,
AggregationServicePassThru passThru) |
Modifier and Type | Method and Description |
---|---|
static AggregationRowPair |
ExprTableEvalStrategyUtil.getRow(ObjectArrayBackedEventBean eventBean) |
Modifier and Type | Method and Description |
---|---|
protected static Object |
ExprTableEvalStrategyUtil.evalAccessorGetValue(AggregationRowPair row,
AggregationAccessorSlotPair pair,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
protected static EventBean |
ExprTableEvalStrategyUtil.evalGetEventBean(AggregationRowPair row,
AggregationAccessorSlotPair pair,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
protected static Collection<EventBean> |
ExprTableEvalStrategyUtil.evalGetROCollectionEvents(AggregationRowPair row,
AggregationAccessorSlotPair pair,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
protected static Collection |
ExprTableEvalStrategyUtil.evalGetROCollectionScalar(AggregationRowPair row,
AggregationAccessorSlotPair pair,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
protected static Map<String,Object> |
ExprTableEvalStrategyUtil.evalMap(ObjectArrayBackedEventBean event,
AggregationRowPair row,
Map<String,TableMetadataColumn> items,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
protected static Object |
ExprTableEvalStrategyUtil.evalMethodGetValue(AggregationRowPair row,
int index) |
protected static Object[] |
ExprTableEvalStrategyUtil.evalTypable(ObjectArrayBackedEventBean event,
AggregationRowPair row,
Map<String,TableMetadataColumn> items,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |