io.siddhi.extension.execution.math

Class PercentileFunctionExtension

java.lang.Object

io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<PercentileAttributeState>

io.siddhi.extension.execution.math.PercentileFunctionExtension

All Implemented Interfaces:

io.siddhi.core.executor.ExpressionExecutor

public class PercentileFunctionExtension
extends io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<PercentileAttributeState>

AttributeAggregator which implements the following function. percentile(value, p) Returns an estimate for the pth percentile of the stored values. Accept Type(s): value: FLOAT,INT,LONG,DOUBLE / p: DOUBLE Return Type: DOUBLE

Field Summary

Fields inherited from class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor

attributeExpressionExecutors

Constructor Summary

Constructors

Constructor and Description
PercentileFunctionExtension()

Method Summary

Modifier and Type	Method and Description
io.siddhi.query.api.definition.Attribute.Type	getReturnType()
protected io.siddhi.core.util.snapshot.state.StateFactory<PercentileAttributeState>	init(io.siddhi.core.executor.ExpressionExecutor[] expressionExecutors, io.siddhi.core.query.processor.ProcessingMode processingMode, boolean b, io.siddhi.core.util.config.ConfigReader configReader, io.siddhi.core.config.SiddhiQueryContext siddhiQueryContext)
Object	processAdd(Object[] data, PercentileAttributeState state)
Object	processAdd(Object data, PercentileAttributeState state)
Object	processRemove(Object[] data, PercentileAttributeState state)
Object	processRemove(Object data, PercentileAttributeState state)
Object	reset(PercentileAttributeState state)

Methods inherited from class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor

execute, initAggregator

Methods inherited from class java.lang.Object

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

Constructor Detail

PercentileFunctionExtension

public PercentileFunctionExtension()

Method Detail

init

protected io.siddhi.core.util.snapshot.state.StateFactory<PercentileAttributeState> init(io.siddhi.core.executor.ExpressionExecutor[] expressionExecutors,
                                                                                         io.siddhi.core.query.processor.ProcessingMode processingMode,
                                                                                         boolean b,
                                                                                         io.siddhi.core.util.config.ConfigReader configReader,
                                                                                         io.siddhi.core.config.SiddhiQueryContext siddhiQueryContext)

Specified by:

init in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<PercentileAttributeState>

processAdd

public Object processAdd(Object data,
                         PercentileAttributeState state)

Specified by:

processAdd in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<PercentileAttributeState>

processAdd

public Object processAdd(Object[] data,
                         PercentileAttributeState state)

Specified by:

processAdd in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<PercentileAttributeState>

processRemove

public Object processRemove(Object data,
                            PercentileAttributeState state)

Specified by:

processRemove in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<PercentileAttributeState>

processRemove

public Object processRemove(Object[] data,
                            PercentileAttributeState state)

Specified by:

processRemove in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<PercentileAttributeState>

reset

public Object reset(PercentileAttributeState state)

Specified by:

reset in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<PercentileAttributeState>

getReturnType

public io.siddhi.query.api.definition.Attribute.Type getReturnType()