public class GroupConcatFunctionExtension
extends io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<io.siddhi.extension.execution.string.GroupConcatFunctionExtension.ExtensionState>
Constructor and Description |
---|
GroupConcatFunctionExtension() |
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.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,
io.siddhi.extension.execution.string.GroupConcatFunctionExtension.ExtensionState extensionState) |
Object |
processAdd(Object o,
io.siddhi.extension.execution.string.GroupConcatFunctionExtension.ExtensionState extensionState) |
Object |
processRemove(Object[] objects,
io.siddhi.extension.execution.string.GroupConcatFunctionExtension.ExtensionState extensionState) |
Object |
processRemove(Object o,
io.siddhi.extension.execution.string.GroupConcatFunctionExtension.ExtensionState extensionState) |
Object |
reset(io.siddhi.extension.execution.string.GroupConcatFunctionExtension.ExtensionState extensionState) |
protected io.siddhi.core.util.snapshot.state.StateFactory<io.siddhi.extension.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)
init
in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<io.siddhi.extension.execution.string.GroupConcatFunctionExtension.ExtensionState>
public Object processAdd(Object o, io.siddhi.extension.execution.string.GroupConcatFunctionExtension.ExtensionState extensionState)
processAdd
in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<io.siddhi.extension.execution.string.GroupConcatFunctionExtension.ExtensionState>
public Object processAdd(Object[] objects, io.siddhi.extension.execution.string.GroupConcatFunctionExtension.ExtensionState extensionState)
processAdd
in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<io.siddhi.extension.execution.string.GroupConcatFunctionExtension.ExtensionState>
public Object processRemove(Object o, io.siddhi.extension.execution.string.GroupConcatFunctionExtension.ExtensionState extensionState)
processRemove
in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<io.siddhi.extension.execution.string.GroupConcatFunctionExtension.ExtensionState>
public Object processRemove(Object[] objects, io.siddhi.extension.execution.string.GroupConcatFunctionExtension.ExtensionState extensionState)
processRemove
in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<io.siddhi.extension.execution.string.GroupConcatFunctionExtension.ExtensionState>
public Object reset(io.siddhi.extension.execution.string.GroupConcatFunctionExtension.ExtensionState extensionState)
reset
in class io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<io.siddhi.extension.execution.string.GroupConcatFunctionExtension.ExtensionState>
public io.siddhi.query.api.definition.Attribute.Type getReturnType()
Copyright © 2019 WSO2. All rights reserved.