org.wso2.extension.siddhi.execution.stats

Class MedianAttributeAggregator

java.lang.Object

org.wso2.siddhi.core.query.selector.attribute.aggregator.AttributeAggregator

org.wso2.extension.siddhi.execution.stats.MedianAttributeAggregator

All Implemented Interfaces:

org.wso2.siddhi.core.util.extension.holder.EternalReferencedHolder, org.wso2.siddhi.core.util.snapshot.Snapshotable

public class MedianAttributeAggregator
extends org.wso2.siddhi.core.query.selector.attribute.aggregator.AttributeAggregator

This extension returns the median of aggregated events.

Field Summary

Fields inherited from class org.wso2.siddhi.core.query.selector.attribute.aggregator.AttributeAggregator

attributeExpressionExecutors, elementId, siddhiAppContext

Constructor Summary

Constructors

Constructor and Description
MedianAttributeAggregator()

Method Summary

Modifier and Type	Method and Description
Map<String,Object>	currentState()
org.wso2.siddhi.query.api.definition.Attribute.Type	getReturnType()
protected void	init(org.wso2.siddhi.core.executor.ExpressionExecutor[] expressionExecutors, org.wso2.siddhi.core.util.config.ConfigReader configReader, org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext)
Object	processAdd(Object data)
Object	processAdd(Object[] data)
Object	processRemove(Object data)
Object	processRemove(Object[] data)
Object	reset()
void	restoreState(Map<String,Object> map)
void	start()
void	stop()

Methods inherited from class org.wso2.siddhi.core.query.selector.attribute.aggregator.AttributeAggregator

cloneAggregator, getElementId, initAggregator, process

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MedianAttributeAggregator

public MedianAttributeAggregator()

Method Detail

init

protected void init(org.wso2.siddhi.core.executor.ExpressionExecutor[] expressionExecutors,
                    org.wso2.siddhi.core.util.config.ConfigReader configReader,
                    org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext)

Specified by:

init in class org.wso2.siddhi.core.query.selector.attribute.aggregator.AttributeAggregator

getReturnType

public org.wso2.siddhi.query.api.definition.Attribute.Type getReturnType()

Specified by:

getReturnType in class org.wso2.siddhi.core.query.selector.attribute.aggregator.AttributeAggregator

processAdd

public Object processAdd(Object data)

Specified by:

processAdd in class org.wso2.siddhi.core.query.selector.attribute.aggregator.AttributeAggregator

processAdd

public Object processAdd(Object[] data)

Specified by:

processAdd in class org.wso2.siddhi.core.query.selector.attribute.aggregator.AttributeAggregator

processRemove

public Object processRemove(Object data)

Specified by:

processRemove in class org.wso2.siddhi.core.query.selector.attribute.aggregator.AttributeAggregator

processRemove

public Object processRemove(Object[] data)

Specified by:

processRemove in class org.wso2.siddhi.core.query.selector.attribute.aggregator.AttributeAggregator

reset

public Object reset()

Specified by:

reset in class org.wso2.siddhi.core.query.selector.attribute.aggregator.AttributeAggregator

start

public void start()

stop

public void stop()

currentState

public Map<String,Object> currentState()

restoreState

public void restoreState(Map<String,Object> map)