public class MedianAttributeAggregator
extends io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<org.wso2.extension.siddhi.execution.stats.MedianAttributeAggregator.ExtensionState>
Constructor and Description |
---|
MedianAttributeAggregator() |
Modifier and Type | Method and Description |
---|---|
io.siddhi.query.api.definition.Attribute.Type |
getReturnType() |
protected io.siddhi.core.util.snapshot.state.StateFactory<org.wso2.extension.siddhi.execution.stats.MedianAttributeAggregator.ExtensionState> |
init(io.siddhi.core.executor.ExpressionExecutor[] attributeExpressionExecutors,
io.siddhi.core.query.processor.ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
io.siddhi.core.util.config.ConfigReader configReader,
io.siddhi.core.config.SiddhiQueryContext siddhiQueryContext) |
Object |
processAdd(Object[] data,
org.wso2.extension.siddhi.execution.stats.MedianAttributeAggregator.ExtensionState state) |
Object |
processAdd(Object data,
org.wso2.extension.siddhi.execution.stats.MedianAttributeAggregator.ExtensionState state) |
Object |
processRemove(Object[] data,
org.wso2.extension.siddhi.execution.stats.MedianAttributeAggregator.ExtensionState state) |
Object |
processRemove(Object data,
org.wso2.extension.siddhi.execution.stats.MedianAttributeAggregator.ExtensionState state) |
Object |
reset(org.wso2.extension.siddhi.execution.stats.MedianAttributeAggregator.ExtensionState state) |
void |
start() |
void |
stop() |
protected io.siddhi.core.util.snapshot.state.StateFactory<org.wso2.extension.siddhi.execution.stats.MedianAttributeAggregator.ExtensionState> init(io.siddhi.core.executor.ExpressionExecutor[] attributeExpressionExecutors, io.siddhi.core.query.processor.ProcessingMode processingMode, boolean outputExpectsExpiredEvents, io.siddhi.core.util.config.ConfigReader configReader, io.siddhi.core.config.SiddhiQueryContext siddhiQueryContext)
init
in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<org.wso2.extension.siddhi.execution.stats.MedianAttributeAggregator.ExtensionState>
public io.siddhi.query.api.definition.Attribute.Type getReturnType()
public Object processAdd(Object data, org.wso2.extension.siddhi.execution.stats.MedianAttributeAggregator.ExtensionState state)
processAdd
in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<org.wso2.extension.siddhi.execution.stats.MedianAttributeAggregator.ExtensionState>
public Object processRemove(Object data, org.wso2.extension.siddhi.execution.stats.MedianAttributeAggregator.ExtensionState state)
processRemove
in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<org.wso2.extension.siddhi.execution.stats.MedianAttributeAggregator.ExtensionState>
public Object processAdd(Object[] data, org.wso2.extension.siddhi.execution.stats.MedianAttributeAggregator.ExtensionState state)
processAdd
in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<org.wso2.extension.siddhi.execution.stats.MedianAttributeAggregator.ExtensionState>
public Object processRemove(Object[] data, org.wso2.extension.siddhi.execution.stats.MedianAttributeAggregator.ExtensionState state)
processRemove
in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<org.wso2.extension.siddhi.execution.stats.MedianAttributeAggregator.ExtensionState>
public Object reset(org.wso2.extension.siddhi.execution.stats.MedianAttributeAggregator.ExtensionState state)
reset
in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<org.wso2.extension.siddhi.execution.stats.MedianAttributeAggregator.ExtensionState>
public void start()
public void stop()
Copyright © 2019 WSO2. All rights reserved.