io.siddhi.extension.execution.json.function

Class GroupAggregatorFunctionExtension

java.lang.Object

io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<io.siddhi.extension.execution.json.function.GroupAggregatorFunctionExtension.ExtensionState>

io.siddhi.extension.execution.json.function.GroupAggregatorFunctionExtension

All Implemented Interfaces:

io.siddhi.core.executor.ExpressionExecutor, Serializable

public class GroupAggregatorFunctionExtension
extends io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<io.siddhi.extension.execution.json.function.GroupAggregatorFunctionExtension.ExtensionState>

group(json, enclosing.element, distinct) Returns JSON object as String by merging all JSON elements if enclosing element is provided. Returns a JSON array as String by adding all JSON elements if enclosing element is not provided

See Also:

Serialized Form

Field Summary

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

attributeExpressionExecutors

Constructor Summary

Constructors

Constructor and Description
GroupAggregatorFunctionExtension()

Method Summary

Modifier and Type	Method and Description
io.siddhi.query.api.definition.Attribute.Type	getReturnType()
protected io.siddhi.core.util.snapshot.state.StateFactory<io.siddhi.extension.execution.json.function.GroupAggregatorFunctionExtension.ExtensionState>	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[] objects, io.siddhi.extension.execution.json.function.GroupAggregatorFunctionExtension.ExtensionState state)
Object	processAdd(Object o, io.siddhi.extension.execution.json.function.GroupAggregatorFunctionExtension.ExtensionState state)
Object	processRemove(Object[] objects, io.siddhi.extension.execution.json.function.GroupAggregatorFunctionExtension.ExtensionState state)
Object	processRemove(Object o, io.siddhi.extension.execution.json.function.GroupAggregatorFunctionExtension.ExtensionState state)
Object	reset(io.siddhi.extension.execution.json.function.GroupAggregatorFunctionExtension.ExtensionState 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

GroupAggregatorFunctionExtension

public GroupAggregatorFunctionExtension()

Method Detail

init

protected io.siddhi.core.util.snapshot.state.StateFactory<io.siddhi.extension.execution.json.function.GroupAggregatorFunctionExtension.ExtensionState> 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<io.siddhi.extension.execution.json.function.GroupAggregatorFunctionExtension.ExtensionState>

processAdd

public Object processAdd(Object o,
                         io.siddhi.extension.execution.json.function.GroupAggregatorFunctionExtension.ExtensionState state)

Specified by:

processAdd in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<io.siddhi.extension.execution.json.function.GroupAggregatorFunctionExtension.ExtensionState>

processAdd

public Object processAdd(Object[] objects,
                         io.siddhi.extension.execution.json.function.GroupAggregatorFunctionExtension.ExtensionState state)

Specified by:

processAdd in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<io.siddhi.extension.execution.json.function.GroupAggregatorFunctionExtension.ExtensionState>

processRemove

public Object processRemove(Object o,
                            io.siddhi.extension.execution.json.function.GroupAggregatorFunctionExtension.ExtensionState state)

Specified by:

processRemove in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<io.siddhi.extension.execution.json.function.GroupAggregatorFunctionExtension.ExtensionState>

processRemove

public Object processRemove(Object[] objects,
                            io.siddhi.extension.execution.json.function.GroupAggregatorFunctionExtension.ExtensionState state)

Specified by:

processRemove in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<io.siddhi.extension.execution.json.function.GroupAggregatorFunctionExtension.ExtensionState>

reset

public Object reset(io.siddhi.extension.execution.json.function.GroupAggregatorFunctionExtension.ExtensionState state)

Specified by:

reset in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<io.siddhi.extension.execution.json.function.GroupAggregatorFunctionExtension.ExtensionState>

getReturnType

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