public class BaseIncrementalValueStore extends Object
Constructor and Description |
---|
BaseIncrementalValueStore(List<ExpressionExecutor> expressionExecutors,
StreamEventFactory streamEventFactory,
SiddhiQueryContext siddhiQueryContext,
String aggregatorName,
ExpressionExecutor shouldUpdateTimestamp,
long initialTimestamp,
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) |
void |
setProcessed(boolean isProcessed) |
void |
setValue(Object value,
int position) |
Object |
shouldUpdate(Object data) |
public BaseIncrementalValueStore(List<ExpressionExecutor> expressionExecutors, StreamEventFactory streamEventFactory, SiddhiQueryContext siddhiQueryContext, String aggregatorName, ExpressionExecutor shouldUpdateTimestamp, long initialTimestamp, boolean groupBy, boolean local)
public void clearValues(long startTimeOfNewAggregates, StreamEvent resetEvent)
public void setValue(Object value, int position)
public List<ExpressionExecutor> getExpressionExecutors()
public boolean isProcessed()
public void setProcessed(boolean isProcessed)
public Map<String,StreamEvent> getGroupedByEvents()
public void process(StreamEvent streamEvent)
public void process(Map<String,StreamEvent> groupedByEvents)
Copyright © 2019. All rights reserved.