public class MaxForeverAttributeAggregatorExecutor extends AttributeAggregatorExecutor<io.siddhi.core.query.selector.attribute.aggregator.MaxForeverAttributeAggregatorExecutor.MaxAggregatorState>
AttributeAggregatorExecutor
to calculate max value for life time based on an event attribute.attributeExpressionExecutors
Constructor and Description |
---|
MaxForeverAttributeAggregatorExecutor() |
Modifier and Type | Method and Description |
---|---|
io.siddhi.query.api.definition.Attribute.Type |
getReturnType() |
protected StateFactory<io.siddhi.core.query.selector.attribute.aggregator.MaxForeverAttributeAggregatorExecutor.MaxAggregatorState> |
init(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
The initialization method for FunctionExecutor
|
Object |
processAdd(Object[] data,
io.siddhi.core.query.selector.attribute.aggregator.MaxForeverAttributeAggregatorExecutor.MaxAggregatorState state) |
Object |
processAdd(Object data,
io.siddhi.core.query.selector.attribute.aggregator.MaxForeverAttributeAggregatorExecutor.MaxAggregatorState state) |
Object |
processRemove(Object[] data,
io.siddhi.core.query.selector.attribute.aggregator.MaxForeverAttributeAggregatorExecutor.MaxAggregatorState state) |
Object |
processRemove(Object data,
io.siddhi.core.query.selector.attribute.aggregator.MaxForeverAttributeAggregatorExecutor.MaxAggregatorState state) |
Object |
reset(io.siddhi.core.query.selector.attribute.aggregator.MaxForeverAttributeAggregatorExecutor.MaxAggregatorState state) |
execute, initAggregator
public MaxForeverAttributeAggregatorExecutor()
protected StateFactory<io.siddhi.core.query.selector.attribute.aggregator.MaxForeverAttributeAggregatorExecutor.MaxAggregatorState> init(ExpressionExecutor[] attributeExpressionExecutors, ProcessingMode processingMode, boolean outputExpectsExpiredEvents, ConfigReader configReader, SiddhiQueryContext siddhiQueryContext)
init
in class AttributeAggregatorExecutor<io.siddhi.core.query.selector.attribute.aggregator.MaxForeverAttributeAggregatorExecutor.MaxAggregatorState>
attributeExpressionExecutors
- are the executors of each attributes in the functionprocessingMode
- query processing modeoutputExpectsExpiredEvents
- is expired events sent as outputconfigReader
- this hold the MaxForeverAttributeAggregatorExecutor
configuration reader.siddhiQueryContext
- Siddhi query runtime contextpublic io.siddhi.query.api.definition.Attribute.Type getReturnType()
public Object processAdd(Object data, io.siddhi.core.query.selector.attribute.aggregator.MaxForeverAttributeAggregatorExecutor.MaxAggregatorState state)
processAdd
in class AttributeAggregatorExecutor<io.siddhi.core.query.selector.attribute.aggregator.MaxForeverAttributeAggregatorExecutor.MaxAggregatorState>
public Object processAdd(Object[] data, io.siddhi.core.query.selector.attribute.aggregator.MaxForeverAttributeAggregatorExecutor.MaxAggregatorState state)
processAdd
in class AttributeAggregatorExecutor<io.siddhi.core.query.selector.attribute.aggregator.MaxForeverAttributeAggregatorExecutor.MaxAggregatorState>
public Object processRemove(Object data, io.siddhi.core.query.selector.attribute.aggregator.MaxForeverAttributeAggregatorExecutor.MaxAggregatorState state)
processRemove
in class AttributeAggregatorExecutor<io.siddhi.core.query.selector.attribute.aggregator.MaxForeverAttributeAggregatorExecutor.MaxAggregatorState>
public Object processRemove(Object[] data, io.siddhi.core.query.selector.attribute.aggregator.MaxForeverAttributeAggregatorExecutor.MaxAggregatorState state)
processRemove
in class AttributeAggregatorExecutor<io.siddhi.core.query.selector.attribute.aggregator.MaxForeverAttributeAggregatorExecutor.MaxAggregatorState>
public Object reset(io.siddhi.core.query.selector.attribute.aggregator.MaxForeverAttributeAggregatorExecutor.MaxAggregatorState state)
reset
in class AttributeAggregatorExecutor<io.siddhi.core.query.selector.attribute.aggregator.MaxForeverAttributeAggregatorExecutor.MaxAggregatorState>
Copyright © 2021. All rights reserved.