public class OutOfOrderEventsDataAggregator extends Object
Constructor and Description |
---|
OutOfOrderEventsDataAggregator(List<ExpressionExecutor> baseExecutors,
ExpressionExecutor shouldUpdateTimestamp,
GroupByKeyGenerator groupByKeyGenerator,
MetaStreamEvent metaStreamEvent) |
Modifier and Type | Method and Description |
---|---|
ComplexEventChunk<StreamEvent> |
aggregateData(ComplexEventChunk<StreamEvent> retrievedData) |
public OutOfOrderEventsDataAggregator(List<ExpressionExecutor> baseExecutors, ExpressionExecutor shouldUpdateTimestamp, GroupByKeyGenerator groupByKeyGenerator, MetaStreamEvent metaStreamEvent)
public ComplexEventChunk<StreamEvent> aggregateData(ComplexEventChunk<StreamEvent> retrievedData)
Copyright © 2021. All rights reserved.