io.siddhi.extension.execution.json.function

Class GroupAsObjectAggregatorFunctionExtension

java.lang.Object

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

io.siddhi.extension.execution.json.function.GroupAsObjectAggregatorFunctionExtension

All Implemented Interfaces:

io.siddhi.core.executor.ExpressionExecutor, Serializable

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

groupAsObject(json, enclosing.element, distinct) Returns JSON object by merging all JSON elements if enclosing element is provided. Returns a JSON array 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
GroupAsObjectAggregatorFunctionExtension()

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.GroupAsObjectAggregatorFunctionExtension.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.GroupAsObjectAggregatorFunctionExtension.ExtensionState extensionState)
Object	processAdd(Object o, io.siddhi.extension.execution.json.function.GroupAsObjectAggregatorFunctionExtension.ExtensionState extensionState)
Object	processRemove(Object[] objects, io.siddhi.extension.execution.json.function.GroupAsObjectAggregatorFunctionExtension.ExtensionState extensionState)
Object	processRemove(Object o, io.siddhi.extension.execution.json.function.GroupAsObjectAggregatorFunctionExtension.ExtensionState extensionState)
Object	reset(io.siddhi.extension.execution.json.function.GroupAsObjectAggregatorFunctionExtension.ExtensionState extensionState)

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

GroupAsObjectAggregatorFunctionExtension

public GroupAsObjectAggregatorFunctionExtension()

Method Detail

init

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

processAdd

public Object processAdd(Object o,
                         io.siddhi.extension.execution.json.function.GroupAsObjectAggregatorFunctionExtension.ExtensionState extensionState)

Specified by:

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

processAdd

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

Specified by:

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

processRemove

public Object processRemove(Object o,
                            io.siddhi.extension.execution.json.function.GroupAsObjectAggregatorFunctionExtension.ExtensionState extensionState)

Specified by:

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

processRemove

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

Specified by:

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

reset

public Object reset(io.siddhi.extension.execution.json.function.GroupAsObjectAggregatorFunctionExtension.ExtensionState extensionState)

Specified by:

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

getReturnType

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