|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Aggregator | |
---|---|
net.esper.eql.expression | EQL expression nodes, aggregation, result set processing |
Uses of Aggregator in net.esper.eql.expression |
---|
Classes in net.esper.eql.expression that implement Aggregator | |
---|---|
static class |
ExprAvedevNode.DoubleAvedev
Standard deviation always generates double-types numbers. |
static class |
ExprAvgNode.DoubleAvg
Average always generates double-types numbers. |
static class |
ExprCountNode.DatapointAggregator
Counts all datapoints including null values. |
static class |
ExprCountNode.NonNullDatapointAggregator
Count all non-null values. |
static class |
ExprMedianNode.DoubleMedian
Average always generates double-types numbers. |
static class |
ExprMinMaxAggrNode.MinMaxAggregator
Min/max aggregator for all values. |
static class |
ExprStddevNode.DoubleStddev
Standard deviation always generates double-types numbers. |
static class |
ExprSumNode.DoubleSum
Sum for double values. |
static class |
ExprSumNode.FloatSum
Sum for float values. |
static class |
ExprSumNode.IntegerSum
Sum for integer values. |
static class |
ExprSumNode.LongSum
Sum for long values. |
static class |
ExprSumNode.NumberIntegerSum
Sum for any number value. |
class |
UniqueValueAggregator
Aggregator for use on top of another aggregator that handles unique value aggregation (versus all-value aggregation) for the underlying aggregator. |
Fields in net.esper.eql.expression declared as Aggregator | |
---|---|
protected Aggregator[] |
AggregationServiceBase.aggregators
Aggregation states and factories. |
Methods in net.esper.eql.expression that return Aggregator | |
---|---|
Aggregator |
ExprSumNode.getAggregationFunction()
|
Aggregator |
ExprStddevNode.getAggregationFunction()
|
Aggregator |
ExprMinMaxAggrNode.getAggregationFunction()
|
Aggregator |
ExprMedianNode.getAggregationFunction()
|
Aggregator |
ExprCountNode.getAggregationFunction()
|
Aggregator |
ExprAvgNode.getAggregationFunction()
|
Aggregator |
ExprAvedevNode.getAggregationFunction()
|
protected abstract Aggregator |
ExprAggregateNode.getAggregationFunction()
Returns the aggregation state prototype for use in grouping aggregation states per group-by keys. |
Aggregator |
ExprAggregateNode.getPrototypeAggregator()
Returns the aggregation state prototype for use in grouping aggregation states per group-by keys. |
Aggregator |
UniqueValueAggregator.newAggregator()
|
Aggregator |
ExprSumNode.NumberIntegerSum.newAggregator()
|
Aggregator |
ExprSumNode.IntegerSum.newAggregator()
|
Aggregator |
ExprSumNode.DoubleSum.newAggregator()
|
Aggregator |
ExprSumNode.LongSum.newAggregator()
|
Aggregator |
ExprSumNode.FloatSum.newAggregator()
|
Aggregator |
ExprStddevNode.DoubleStddev.newAggregator()
|
Aggregator |
ExprMinMaxAggrNode.MinMaxAggregator.newAggregator()
|
Aggregator |
ExprMedianNode.DoubleMedian.newAggregator()
|
Aggregator |
ExprCountNode.DatapointAggregator.newAggregator()
|
Aggregator |
ExprCountNode.NonNullDatapointAggregator.newAggregator()
|
Aggregator |
ExprAvgNode.DoubleAvg.newAggregator()
|
Aggregator |
ExprAvedevNode.DoubleAvedev.newAggregator()
|
Aggregator |
Aggregator.newAggregator()
Make a new, initalized aggregation state. |
Constructors in net.esper.eql.expression with parameters of type Aggregator | |
---|---|
AggregationServiceBase(ExprEvaluator[] evaluators,
Aggregator[] aggregators)
Ctor. |
|
AggregationServiceGroupAllImpl(ExprEvaluator[] evaluators,
Aggregator[] aggregators)
Ctor. |
|
AggregationServiceGroupByImpl(ExprEvaluator[] evaluators,
Aggregator[] aggregators)
Ctor. |
|
UniqueValueAggregator(Aggregator inner)
Ctor. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |