Module org.elasticsearch.compute
Class RateDoubleAggregator
java.lang.Object
org.elasticsearch.compute.aggregation.RateDoubleAggregator
A rate grouping aggregation definition for double.
This class is generated. Edit `X-RateAggregator.java.st` instead.
-
Nested Class Summary
Nested Classes -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic voidcombine(RateDoubleAggregator.DoubleRateGroupingState current, int groupId, long timestamp, double value) static voidcombineIntermediate(RateDoubleAggregator.DoubleRateGroupingState current, int groupId, LongBlock timestamps, DoubleBlock values, double reset, int otherPosition) static voidcombineStates(RateDoubleAggregator.DoubleRateGroupingState current, int currentGroupId, RateDoubleAggregator.DoubleRateGroupingState otherState, int otherGroupId) static BlockevaluateFinal(RateDoubleAggregator.DoubleRateGroupingState state, IntVector selected, DriverContext driverContext) initGrouping(DriverContext driverContext, long unitInMillis)
-
Constructor Details
-
RateDoubleAggregator
public RateDoubleAggregator()
-
-
Method Details
-
initGrouping
public static RateDoubleAggregator.DoubleRateGroupingState initGrouping(DriverContext driverContext, long unitInMillis) -
combine
public static void combine(RateDoubleAggregator.DoubleRateGroupingState current, int groupId, long timestamp, double value) -
combineIntermediate
public static void combineIntermediate(RateDoubleAggregator.DoubleRateGroupingState current, int groupId, LongBlock timestamps, DoubleBlock values, double reset, int otherPosition) -
combineStates
public static void combineStates(RateDoubleAggregator.DoubleRateGroupingState current, int currentGroupId, RateDoubleAggregator.DoubleRateGroupingState otherState, int otherGroupId) -
evaluateFinal
public static Block evaluateFinal(RateDoubleAggregator.DoubleRateGroupingState state, IntVector selected, DriverContext driverContext)
-