Package | Description |
---|---|
com.espertech.esper.epl.agg.factory |
Aggregator factories
|
com.espertech.esper.epl.agg.service |
Aggregation services.
|
com.espertech.esper.epl.table.mgmt |
Table-related services and metadata.
|
Modifier and Type | Method and Description |
---|---|
AggregationState |
AggregationStateFactorySorted.createAccess(int agentInstanceId,
boolean join,
Object groupKey,
AggregationServicePassThru passThru) |
AggregationState |
AggregationStateFactoryPlugin.createAccess(int agentInstanceId,
boolean join,
Object groupBy,
AggregationServicePassThru passThru) |
AggregationState |
AggregationStateFactoryMinMaxByEver.createAccess(int agentInstanceId,
boolean join,
Object groupKey,
AggregationServicePassThru passThru) |
AggregationState |
AggregationStateFactoryLinear.createAccess(int agentInstanceId,
boolean join,
Object groupKey,
AggregationServicePassThru passThru) |
AggregationState |
AggregationStateFactoryCountMinSketch.createAccess(int agentInstanceId,
boolean join,
Object groupKey,
AggregationServicePassThru passThru) |
Modifier and Type | Method and Description |
---|---|
AggregationState |
AggregationStateFactory.createAccess(int agentInstanceId,
boolean join,
Object groupKey,
AggregationServicePassThru passThru) |
static AggregationState[] |
AggSvcGroupByUtil.newAccesses(int agentInstanceId,
boolean isJoin,
AggregationStateFactory[] accessAggSpecs,
Object groupKey,
AggregationServicePassThru passThru) |
Modifier and Type | Method and Description |
---|---|
AggregationServicePassThru |
TableStateInstanceUngroupedImpl.getAggregationServicePassThru() |
AggregationServicePassThru |
TableStateInstanceGroupedImpl.getAggregationServicePassThru() |
abstract AggregationServicePassThru |
TableStateInstance.getAggregationServicePassThru() |
Modifier and Type | Method and Description |
---|---|
AggregationRowPair |
TableStateRowFactory.makeAggs(int agentInstanceId,
Object groupByKey,
Object groupKeyBinding,
AggregationServicePassThru passThru) |
ObjectArrayBackedEventBean |
TableStateRowFactory.makeOA(int agentInstanceId,
Object groupByKey,
Object groupKeyBinding,
AggregationServicePassThru passThru) |