Package | Description |
---|---|
com.espertech.esper.epl.agg.factory |
Aggregator factories
|
com.espertech.esper.epl.agg.service.common |
Aggregation services - common.
|
com.espertech.esper.epl.table.mgmt |
Table-related services and metadata.
|
Modifier and Type | Method and Description |
---|---|
AggregationState |
AggregationStateSortedFactory.createAccess(int agentInstanceId,
boolean join,
java.lang.Object groupKey,
AggregationServicePassThru passThru) |
AggregationState |
AggregationStatePluginFactory.createAccess(int agentInstanceId,
boolean join,
java.lang.Object groupBy,
AggregationServicePassThru passThru) |
AggregationState |
AggregationStateMinMaxByEverFactory.createAccess(int agentInstanceId,
boolean join,
java.lang.Object groupKey,
AggregationServicePassThru passThru) |
AggregationState |
AggregationStateLinearFactory.createAccess(int agentInstanceId,
boolean join,
java.lang.Object groupKey,
AggregationServicePassThru passThru) |
AggregationState |
AggregationStateFactoryCountMinSketch.createAccess(int agentInstanceId,
boolean join,
java.lang.Object groupKey,
AggregationServicePassThru passThru) |
Modifier and Type | Method and Description |
---|---|
AggregationState |
AggregationStateFactory.createAccess(int agentInstanceId,
boolean join,
java.lang.Object groupKey,
AggregationServicePassThru passThru) |
static AggregationState[] |
AggSvcGroupByUtil.newAccesses(int agentInstanceId,
boolean isJoin,
AggregationStateFactory[] accessAggSpecs,
java.lang.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,
java.lang.Object groupByKey,
java.lang.Object groupKeyBinding,
AggregationServicePassThru passThru) |
ObjectArrayBackedEventBean |
TableStateRowFactory.makeOA(int agentInstanceId,
java.lang.Object groupByKey,
java.lang.Object groupKeyBinding,
AggregationServicePassThru passThru) |