org.wso2.extension.siddhi.execution.string

Class GroupConcatFunctionExtension

java.lang.Object

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

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

All Implemented Interfaces:

org.wso2.siddhi.core.util.snapshot.Snapshotable

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

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 org.wso2.siddhi.core.query.selector.attribute.aggregator.AttributeAggregator

attributeExpressionExecutors, elementId, siddhiAppContext

Constructor Summary

Constructors

Constructor and Description
GroupConcatFunctionExtension()

Method Summary

Modifier and Type	Method and Description
boolean	canDestroy()
Map<String,Object>	currentState()
org.wso2.siddhi.query.api.definition.Attribute.Type	getReturnType()
protected void	init(org.wso2.siddhi.core.executor.ExpressionExecutor[] attributeExpressionExecutors, org.wso2.siddhi.core.util.config.ConfigReader configReader, org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext)
Object	processAdd(Object o)
Object	processAdd(Object[] objects)
Object	processRemove(Object o)
Object	processRemove(Object[] objects)
Object	reset()
void	restoreState(Map<String,Object> state)

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

GroupConcatFunctionExtension

public GroupConcatFunctionExtension()

Method Detail

init

protected void init(org.wso2.siddhi.core.executor.ExpressionExecutor[] attributeExpressionExecutors,
                    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 o)

Specified by:

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

processAdd

public Object processAdd(Object[] objects)

Specified by:

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

processRemove

public Object processRemove(Object o)

Specified by:

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

processRemove

public Object processRemove(Object[] objects)

Specified by:

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

canDestroy

public boolean canDestroy()

Specified by:

canDestroy 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

currentState

public Map<String,Object> currentState()

restoreState

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