public class BaseIncrementalValueStore extends Object
Constructor and Description |
---|
BaseIncrementalValueStore(String aggregatorName,
long initialTimestamp,
List<ExpressionExecutor> expressionExecutors,
ExpressionExecutor shouldUpdateTimestamp,
StreamEventFactory streamEventFactory,
SiddhiQueryContext siddhiQueryContext,
boolean groupBy,
boolean local) |
Modifier and Type | Method and Description |
---|---|
void |
clearValues(long startTimeOfNewAggregates,
StreamEvent resetEvent) |
List<ExpressionExecutor> |
getExpressionExecutors() |
Map<String,StreamEvent> |
getGroupedByEvents() |
boolean |
isProcessed() |
void |
process(Map<String,StreamEvent> groupedByEvents) |
void |
process(StreamEvent streamEvent) |
public BaseIncrementalValueStore(String aggregatorName, long initialTimestamp, List<ExpressionExecutor> expressionExecutors, ExpressionExecutor shouldUpdateTimestamp, StreamEventFactory streamEventFactory, SiddhiQueryContext siddhiQueryContext, boolean groupBy, boolean local)
public void clearValues(long startTimeOfNewAggregates, StreamEvent resetEvent)
public List<ExpressionExecutor> getExpressionExecutors()
public boolean isProcessed()
public Map<String,StreamEvent> getGroupedByEvents()
public void process(StreamEvent streamEvent)
public void process(Map<String,StreamEvent> groupedByEvents)
Copyright © 2019. All rights reserved.