Module org.elasticsearch.compute
Class FirstBytesRefByTimestampAggregator
java.lang.Object
org.elasticsearch.compute.aggregation.FirstBytesRefByTimestampAggregator
A time-series aggregation function that collects the First occurrence value of a time series in a specified interval.
This class is generated. Edit `X-ValueByTimestampAggregator.java.st` instead.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic final class -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic voidcombine(FirstBytesRefByTimestampAggregator.GroupingState current, int groupId, org.apache.lucene.util.BytesRef value, long timestamp) static voidcombine(org.elasticsearch.compute.aggregation.LongBytesRefState current, org.apache.lucene.util.BytesRef value, long timestamp) static voidcombineIntermediate(FirstBytesRefByTimestampAggregator.GroupingState current, int groupId, LongBlock timestamps, BytesRefBlock values, int otherPosition) static voidcombineIntermediate(org.elasticsearch.compute.aggregation.LongBytesRefState current, long timestamp, org.apache.lucene.util.BytesRef value, boolean seen) static Stringdescribe()static BlockevaluateFinal(FirstBytesRefByTimestampAggregator.GroupingState state, IntVector selected, GroupingAggregatorEvaluationContext ctx) static BlockevaluateFinal(org.elasticsearch.compute.aggregation.LongBytesRefState current, DriverContext ctx) static voidfirst(org.elasticsearch.compute.aggregation.LongBytesRefState current, org.apache.lucene.util.BytesRef value, long timestamp) initGrouping(DriverContext driverContext) static org.elasticsearch.compute.aggregation.LongBytesRefStateinitSingle(DriverContext driverContext)
-
Constructor Details
-
FirstBytesRefByTimestampAggregator
public FirstBytesRefByTimestampAggregator()
-
-
Method Details
-
describe
-
initSingle
public static org.elasticsearch.compute.aggregation.LongBytesRefState initSingle(DriverContext driverContext) -
first
public static void first(org.elasticsearch.compute.aggregation.LongBytesRefState current, org.apache.lucene.util.BytesRef value, long timestamp) -
combine
public static void combine(org.elasticsearch.compute.aggregation.LongBytesRefState current, org.apache.lucene.util.BytesRef value, long timestamp) -
combineIntermediate
public static void combineIntermediate(org.elasticsearch.compute.aggregation.LongBytesRefState current, long timestamp, org.apache.lucene.util.BytesRef value, boolean seen) -
evaluateFinal
public static Block evaluateFinal(org.elasticsearch.compute.aggregation.LongBytesRefState current, DriverContext ctx) -
initGrouping
public static FirstBytesRefByTimestampAggregator.GroupingState initGrouping(DriverContext driverContext) -
combine
public static void combine(FirstBytesRefByTimestampAggregator.GroupingState current, int groupId, org.apache.lucene.util.BytesRef value, long timestamp) -
combineIntermediate
public static void combineIntermediate(FirstBytesRefByTimestampAggregator.GroupingState current, int groupId, LongBlock timestamps, BytesRefBlock values, int otherPosition) -
evaluateFinal
public static Block evaluateFinal(FirstBytesRefByTimestampAggregator.GroupingState state, IntVector selected, GroupingAggregatorEvaluationContext ctx)
-