org.wso2.extension.siddhi.execution.string

Class GroupConcatFunctionExtension

java.lang.Object

io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<org.wso2.extension.siddhi.execution.string.GroupConcatFunctionExtension.ExtensionState>

org.wso2.extension.siddhi.execution.string.GroupConcatFunctionExtension

All Implemented Interfaces:

io.siddhi.core.executor.ExpressionExecutor

public class GroupConcatFunctionExtension
extends io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<org.wso2.extension.siddhi.execution.string.GroupConcatFunctionExtension.ExtensionState>

groupConcat(string1, 'separator', bool, 'ASC/DESC') Returns concated string for all the events separated by the given separator. Accept Type(s): STRING. The string that need to be aggregated. Accept Type(s): STRING. The separator that separates each string that gets aggregated. Accept Type(s): BOOL. To only have distinct string keys in the the aggregation.. Accept Type(s): STRING. Accepts 'ASC' or 'DESC' strings to sort the string keys by ascending or descending order. Return Type(s): STRING

Field Summary

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

attributeExpressionExecutors

Constructor Summary

Constructors

Constructor and Description
GroupConcatFunctionExtension()

Method Summary

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.string.GroupConcatFunctionExtension.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, org.wso2.extension.siddhi.execution.string.GroupConcatFunctionExtension.ExtensionState extensionState)
Object	processAdd(Object o, org.wso2.extension.siddhi.execution.string.GroupConcatFunctionExtension.ExtensionState extensionState)
Object	processRemove(Object[] objects, org.wso2.extension.siddhi.execution.string.GroupConcatFunctionExtension.ExtensionState extensionState)
Object	processRemove(Object o, org.wso2.extension.siddhi.execution.string.GroupConcatFunctionExtension.ExtensionState extensionState)
Object	reset(org.wso2.extension.siddhi.execution.string.GroupConcatFunctionExtension.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

GroupConcatFunctionExtension

public GroupConcatFunctionExtension()

Method Detail

init

protected io.siddhi.core.util.snapshot.state.StateFactory<org.wso2.extension.siddhi.execution.string.GroupConcatFunctionExtension.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<org.wso2.extension.siddhi.execution.string.GroupConcatFunctionExtension.ExtensionState>

processAdd

public Object processAdd(Object o,
                         org.wso2.extension.siddhi.execution.string.GroupConcatFunctionExtension.ExtensionState extensionState)

Specified by:

processAdd in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<org.wso2.extension.siddhi.execution.string.GroupConcatFunctionExtension.ExtensionState>

processAdd

public Object processAdd(Object[] objects,
                         org.wso2.extension.siddhi.execution.string.GroupConcatFunctionExtension.ExtensionState extensionState)

Specified by:

processAdd in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<org.wso2.extension.siddhi.execution.string.GroupConcatFunctionExtension.ExtensionState>

processRemove

public Object processRemove(Object o,
                            org.wso2.extension.siddhi.execution.string.GroupConcatFunctionExtension.ExtensionState extensionState)

Specified by:

processRemove in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<org.wso2.extension.siddhi.execution.string.GroupConcatFunctionExtension.ExtensionState>

processRemove

public Object processRemove(Object[] objects,
                            org.wso2.extension.siddhi.execution.string.GroupConcatFunctionExtension.ExtensionState extensionState)

Specified by:

processRemove in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<org.wso2.extension.siddhi.execution.string.GroupConcatFunctionExtension.ExtensionState>

reset

public Object reset(org.wso2.extension.siddhi.execution.string.GroupConcatFunctionExtension.ExtensionState extensionState)

Specified by:

reset in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<org.wso2.extension.siddhi.execution.string.GroupConcatFunctionExtension.ExtensionState>

getReturnType

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