Package | Description |
---|---|
com.espertech.esper.client.hook |
Callback interfaces for use with statement annotations.
|
com.espertech.esper.epl.agg.aggregator |
Aggregation function implementations.
|
com.espertech.esper.epl.agg.factory |
Aggregator factories
|
com.espertech.esper.epl.agg.service |
Aggregation services.
|
com.espertech.esper.epl.expression.accessagg |
Access-aggregation expressions.
|
com.espertech.esper.metrics.instrumentation |
EPL instrumentation helpers.
|
Modifier and Type | Method and Description |
---|---|
AggregationMethod |
AggregationFunctionFactory.newAggregator()
Make a new, initalized aggregation state.
|
Modifier and Type | Class and Description |
---|---|
class |
AggregatorAvedev
Standard deviation always generates double-types numbers.
|
class |
AggregatorAvedevFilter
Standard deviation always generates double-types numbers.
|
class |
AggregatorAvg
Average that generates double-typed numbers.
|
class |
AggregatorAvgBigDecimal
Average that generates a BigDecimal numbers.
|
class |
AggregatorAvgBigDecimalFilter
Average that generates a BigDecimal numbers.
|
class |
AggregatorAvgFilter
Average that generates double-typed numbers.
|
class |
AggregatorCount
Counts all datapoints including null values.
|
class |
AggregatorCountEver
Aggregator for count-ever value.
|
class |
AggregatorCountEverFilter
Aggregator for the count-ever value.
|
class |
AggregatorCountEverNonNull
Aggregator for count-ever value.
|
class |
AggregatorCountEverNonNullFilter
Aggregator for the count-ever value.
|
class |
AggregatorCountFilter
Counts all datapoints including null values.
|
class |
AggregatorCountNonNull
Count all non-null values.
|
class |
AggregatorCountNonNullFilter
Count all non-null values.
|
class |
AggregatorDistinctValue
AggregationMethod for use on top of another aggregator that handles unique value aggregation (versus all-value aggregation)
for the underlying aggregator.
|
class |
AggregatorDistinctValueFilter
AggregationMethod for use on top of another aggregator that handles unique value aggregation (versus all-value aggregation)
for the underlying aggregator.
|
class |
AggregatorFirstEver
Aggregator for the very first value.
|
class |
AggregatorFirstEverFilter
Aggregator for the very first value.
|
class |
AggregatorLastEver
Aggregator for the very last value.
|
class |
AggregatorLastEverFilter
Aggregator for the very last value.
|
class |
AggregatorLeaving
For testing if a remove stream entry has been present.
|
class |
AggregatorLeavingFilter
Aggregator for the very last value.
|
class |
AggregatorMedian
Median aggregation.
|
class |
AggregatorMedianFilter
Median aggregation.
|
class |
AggregatorMinMax
Min/max aggregator for all values.
|
class |
AggregatorMinMaxEver
Min/max aggregator for all values, not considering events leaving the aggregation (i.e.
|
class |
AggregatorMinMaxEverFilter
Min/max aggregator for all values, not considering events leaving the aggregation (i.e.
|
class |
AggregatorMinMaxFilter
Min/max aggregator for all values.
|
class |
AggregatorNth
Aggregator to return the Nth oldest element to enter, with N=1 the most recent
value is returned.
|
class |
AggregatorNthFilter |
class |
AggregatorRate
Aggregation computing an event arrival rate for data windowed-events.
|
class |
AggregatorRateEver
Aggregation computing an event arrival rate for with and without data window.
|
class |
AggregatorRateEverFilter |
class |
AggregatorRateFilter |
class |
AggregatorStddev
Standard deviation always generates double-typed numbers.
|
class |
AggregatorStddevFilter
Standard deviation always generates double-typed numbers.
|
class |
AggregatorSumBigDecimal
Sum for BigInteger values.
|
class |
AggregatorSumBigDecimalFilter
Sum for BigInteger values.
|
class |
AggregatorSumBigInteger
Sum for BigInteger values.
|
class |
AggregatorSumBigIntegerFilter
Sum for BigInteger values.
|
class |
AggregatorSumDouble
Sum for double values.
|
class |
AggregatorSumDoubleFilter
Sum for double values.
|
class |
AggregatorSumFloat
Sum for float values.
|
class |
AggregatorSumFloatFilter
Sum for float values.
|
class |
AggregatorSumInteger
Sum for integer values.
|
class |
AggregatorSumIntegerFilter
Sum for integer values.
|
class |
AggregatorSumLong
Sum for long values.
|
class |
AggregatorSumLongFilter
Sum for long values.
|
class |
AggregatorSumNumInteger
Sum for any number value.
|
class |
AggregatorSumNumIntegerFilter
Sum for any number value.
|
Modifier and Type | Field and Description |
---|---|
protected AggregationMethod |
AggregatorDistinctValueFilter.inner |
protected AggregationMethod |
AggregatorDistinctValue.inner |
Constructor and Description |
---|
AggregatorDistinctValue(AggregationMethod inner)
Ctor.
|
AggregatorDistinctValueFilter(AggregationMethod inner)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
AggregationMethod |
AggregationMethodFactorySum.make() |
AggregationMethod |
AggregationMethodFactoryStddev.make() |
AggregationMethod |
AggregationMethodFactoryRate.make() |
AggregationMethod |
AggregationMethodFactoryPlugIn.make() |
AggregationMethod |
AggregationMethodFactoryNth.make() |
AggregationMethod |
AggregationMethodFactoryMinMax.make() |
AggregationMethod |
AggregationMethodFactoryMedian.make() |
AggregationMethod |
AggregationMethodFactoryLeaving.make() |
AggregationMethod |
AggregationMethodFactoryLastEver.make() |
AggregationMethod |
AggregationMethodFactoryFirstEver.make() |
AggregationMethod |
AggregationMethodFactoryCountEver.make() |
AggregationMethod |
AggregationMethodFactoryCount.make() |
AggregationMethod |
AggregationMethodFactoryAvg.make() |
AggregationMethod |
AggregationMethodFactoryAvedev.make() |
static AggregationMethod |
AggregationMethodFactoryUtil.makeDistinctAggregator(AggregationMethod aggregationMethod,
boolean hasFilter) |
static AggregationMethod |
AggregationMethodFactoryUtil.makeFirstEver(boolean hasFilter) |
static AggregationMethod |
AggregationMethodFactoryUtil.makeLastEver(boolean hasFilter) |
Modifier and Type | Method and Description |
---|---|
static AggregationMethod |
AggregationMethodFactoryUtil.makeDistinctAggregator(AggregationMethod aggregationMethod,
boolean hasFilter) |
Modifier and Type | Field and Description |
---|---|
protected AggregationMethod[] |
AggregationServiceBaseUngrouped.aggregators
Aggregation states.
|
protected AggregationMethod[] |
AggSvcGroupLocalGroupByBase.aggregatorsTopLevel |
protected AggregationMethod[] |
AggSvcGroupByWTableBase.currentAggregatorMethods |
Modifier and Type | Method and Description |
---|---|
AggregationMethod[] |
AggSvcGroupLocalGroupByBase.getAggregatorsTopLevel() |
AggregationMethod[] |
AggregationRowPair.getMethods()
Returns aggregation methods.
|
AggregationMethod[] |
AggregationMethodRowAged.getMethods()
Returns aggregation state.
|
AggregationMethod[] |
AggregationMethodRow.getMethods()
Returns aggregation state.
|
AggregationMethod[] |
AggregationMethodPairRow.getMethods()
Returns aggregation state.
|
AggregationMethod |
AggregationMethodFactory.make() |
static AggregationMethod[] |
AggSvcGroupByUtil.newAggregators(AggregationMethodFactory[] prototypes) |
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 static void |
AggSvcGroupLocalGroupByBase.clearResults(Map<Object,AggregationMethodPairRow>[] aggregatorsPerLevelAndGroup,
AggregationMethod[] aggregatorsTopLevel,
AggregationState[] statesTopLevel) |
void |
AggSvcGroupLocalGroupByBase.setAggregatorsTopLevel(AggregationMethod[] aggregatorsTopLevel) |
Modifier and Type | Method and Description |
---|---|
AggregationMethod |
ExprPlugInAggMultiFunctionNodeFactory.make() |
AggregationMethod |
ExprAggMultiFunctionSortedMinMaxByNodeFactory.make() |
AggregationMethod |
ExprAggMultiFunctionLinearAccessNodeFactoryAccess.make() |
AggregationMethod |
ExprAggCountMinSketchNodeFactoryBase.make() |
AggregationMethod |
AggregationMethodFactoryFirstLastUnbound.make() |
Modifier and Type | Method and Description |
---|---|
void |
InstrumentationDefault.aAggNoAccessEnterLeave(boolean enter,
int index,
AggregationMethod aggregationMethod) |
void |
Instrumentation.aAggNoAccessEnterLeave(boolean enter,
int index,
AggregationMethod aggregationMethod) |
void |
InstrumentationDefault.qAggNoAccessEnterLeave(boolean enter,
int index,
AggregationMethod aggregationMethod,
ExprNode aggExpr) |
void |
Instrumentation.qAggNoAccessEnterLeave(boolean enter,
int index,
AggregationMethod aggregationMethod,
ExprNode aggExpr) |