public class MinAttributeAggregatorExecutor extends AttributeAggregatorExecutor<io.siddhi.core.query.selector.attribute.aggregator.MinAttributeAggregatorExecutor.MinAggregatorState>
AttributeAggregatorExecutor
to calculate min value based on an event attribute.attributeExpressionExecutors
Constructor and Description |
---|
MinAttributeAggregatorExecutor() |
Modifier and Type | Method and Description |
---|---|
io.siddhi.query.api.definition.Attribute.Type |
getReturnType() |
void |
init(io.siddhi.query.api.definition.Attribute.Type type) |
protected StateFactory<io.siddhi.core.query.selector.attribute.aggregator.MinAttributeAggregatorExecutor.MinAggregatorState> |
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.MinAttributeAggregatorExecutor.MinAggregatorState state) |
Object |
processAdd(Object data,
io.siddhi.core.query.selector.attribute.aggregator.MinAttributeAggregatorExecutor.MinAggregatorState state) |
Object |
processRemove(Object[] data,
io.siddhi.core.query.selector.attribute.aggregator.MinAttributeAggregatorExecutor.MinAggregatorState state) |
Object |
processRemove(Object data,
io.siddhi.core.query.selector.attribute.aggregator.MinAttributeAggregatorExecutor.MinAggregatorState state) |
Object |
reset(io.siddhi.core.query.selector.attribute.aggregator.MinAttributeAggregatorExecutor.MinAggregatorState state) |
execute, initAggregator
public void init(io.siddhi.query.api.definition.Attribute.Type type)
protected StateFactory<io.siddhi.core.query.selector.attribute.aggregator.MinAttributeAggregatorExecutor.MinAggregatorState> init(ExpressionExecutor[] attributeExpressionExecutors, ProcessingMode processingMode, boolean outputExpectsExpiredEvents, ConfigReader configReader, SiddhiQueryContext siddhiQueryContext)
init
in class AttributeAggregatorExecutor<io.siddhi.core.query.selector.attribute.aggregator.MinAttributeAggregatorExecutor.MinAggregatorState>
attributeExpressionExecutors
- are the executors of each attributes in the functionprocessingMode
- query processing modeoutputExpectsExpiredEvents
- is expired events sent as outputconfigReader
- this hold the MinAttributeAggregatorExecutor
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.MinAttributeAggregatorExecutor.MinAggregatorState state)
processAdd
in class AttributeAggregatorExecutor<io.siddhi.core.query.selector.attribute.aggregator.MinAttributeAggregatorExecutor.MinAggregatorState>
public Object processAdd(Object[] data, io.siddhi.core.query.selector.attribute.aggregator.MinAttributeAggregatorExecutor.MinAggregatorState state)
processAdd
in class AttributeAggregatorExecutor<io.siddhi.core.query.selector.attribute.aggregator.MinAttributeAggregatorExecutor.MinAggregatorState>
public Object processRemove(Object data, io.siddhi.core.query.selector.attribute.aggregator.MinAttributeAggregatorExecutor.MinAggregatorState state)
processRemove
in class AttributeAggregatorExecutor<io.siddhi.core.query.selector.attribute.aggregator.MinAttributeAggregatorExecutor.MinAggregatorState>
public Object processRemove(Object[] data, io.siddhi.core.query.selector.attribute.aggregator.MinAttributeAggregatorExecutor.MinAggregatorState state)
processRemove
in class AttributeAggregatorExecutor<io.siddhi.core.query.selector.attribute.aggregator.MinAttributeAggregatorExecutor.MinAggregatorState>
public Object reset(io.siddhi.core.query.selector.attribute.aggregator.MinAttributeAggregatorExecutor.MinAggregatorState state)
reset
in class AttributeAggregatorExecutor<io.siddhi.core.query.selector.attribute.aggregator.MinAttributeAggregatorExecutor.MinAggregatorState>
Copyright © 2021. All rights reserved.