S
- current state for the Attribute Executorpublic abstract class AttributeAggregatorExecutor<S extends State> extends Object implements ExpressionExecutor
Modifier and Type | Field and Description |
---|---|
protected ExpressionExecutor[] |
attributeExpressionExecutors |
Constructor and Description |
---|
AttributeAggregatorExecutor() |
Modifier and Type | Method and Description |
---|---|
Object |
execute(ComplexEvent event) |
protected abstract StateFactory<S> |
init(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
The initialization method for FunctionExecutor
|
void |
initAggregator(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
ConfigReader configReader,
boolean groupBy,
SiddhiQueryContext siddhiQueryContext) |
abstract Object |
processAdd(Object[] data,
S state) |
abstract Object |
processAdd(Object data,
S state) |
abstract Object |
processRemove(Object[] data,
S state) |
abstract Object |
processRemove(Object data,
S state) |
abstract Object |
reset(S state) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getReturnType
protected ExpressionExecutor[] attributeExpressionExecutors
public void initAggregator(ExpressionExecutor[] attributeExpressionExecutors, ProcessingMode processingMode, boolean outputExpectsExpiredEvents, ConfigReader configReader, boolean groupBy, SiddhiQueryContext siddhiQueryContext)
public Object execute(ComplexEvent event)
execute
in interface ExpressionExecutor
protected abstract StateFactory<S> init(ExpressionExecutor[] attributeExpressionExecutors, ProcessingMode processingMode, boolean outputExpectsExpiredEvents, ConfigReader configReader, SiddhiQueryContext siddhiQueryContext)
attributeExpressionExecutors
- are the executors of each attributes in the functionprocessingMode
- query processing modeoutputExpectsExpiredEvents
- is expired events sent as outputconfigReader
- this hold the AttributeAggregatorExecutor
extensions
configuration reader.siddhiQueryContext
- Siddhi query runtime contextCopyright © 2019. All rights reserved.