io.siddhi.extension.execution.map

## Class CollectAggregateFunction

- java.lang.Object
- - io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<io.siddhi.core.util.snapshot.state.State>
  - - io.siddhi.extension.execution.map.CollectAggregateFunction

- All Implemented Interfaces:
    io.siddhi.core.executor.ExpressionExecutor

      public class CollectAggregateFunction
      extends io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<io.siddhi.core.util.snapshot.state.State>

  Implementation class for map:collect()

- - ### Field Summary

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

      `attributeExpressionExecutors`

  - ### Constructor Summary

    Constructors
    Constructor and Description
    `CollectAggregateFunction()`

  - ### Method Summary

    All Methods Instance Methods Concrete Methods
    Modifier and Type | Method and Description
    --- | ---
    `io.siddhi.query.api.definition.Attribute.Type` | `getReturnType()`
    `protected io.siddhi.core.util.snapshot.state.StateFactory<io.siddhi.core.util.snapshot.state.State>` | `init(io.siddhi.core.executor.ExpressionExecutor[] expressionExecutors, io.siddhi.core.query.processor.ProcessingMode processingMode, boolean outputExpectsExpiredEvents, io.siddhi.core.util.config.ConfigReader configReader, io.siddhi.core.config.SiddhiQueryContext siddhiQueryContext)`
    `Object` | `processAdd(Object[] objects, io.siddhi.core.util.snapshot.state.State state)`
    `Object` | `processAdd(Object object, io.siddhi.core.util.snapshot.state.State state)`
    `Object` | `processRemove(Object[] objects, io.siddhi.core.util.snapshot.state.State state)`
    `Object` | `processRemove(Object object, io.siddhi.core.util.snapshot.state.State state)`
    `Object` | `reset(io.siddhi.core.util.snapshot.state.State 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

    - #### CollectAggregateFunction

          public CollectAggregateFunction()

  - ### Method Detail

    - #### init

          protected io.siddhi.core.util.snapshot.state.StateFactory<io.siddhi.core.util.snapshot.state.State> init(io.siddhi.core.executor.ExpressionExecutor[] expressionExecutors,
                                                                                                                   io.siddhi.core.query.processor.ProcessingMode processingMode,
                                                                                                                   boolean outputExpectsExpiredEvents,
                                                                                                                   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.core.util.snapshot.state.State>`

    - #### processAdd

          public Object processAdd(Object object,
                                   io.siddhi.core.util.snapshot.state.State state)

      Specified by:
        `processAdd` in class `io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<io.siddhi.core.util.snapshot.state.State>`

    - #### processAdd

          public Object processAdd(Object[] objects,
                                   io.siddhi.core.util.snapshot.state.State state)

      Specified by:
        `processAdd` in class `io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<io.siddhi.core.util.snapshot.state.State>`

    - #### processRemove

          public Object processRemove(Object object,
                                      io.siddhi.core.util.snapshot.state.State state)

      Specified by:
        `processRemove` in class `io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<io.siddhi.core.util.snapshot.state.State>`

    - #### processRemove

          public Object processRemove(Object[] objects,
                                      io.siddhi.core.util.snapshot.state.State state)

      Specified by:
        `processRemove` in class `io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<io.siddhi.core.util.snapshot.state.State>`

    - #### getReturnType

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

    - #### reset

          public Object reset(io.siddhi.core.util.snapshot.state.State state)

      Specified by:
        `reset` in class `io.siddhi.core.query.selector.attribute.aggregator.AttributeAggregatorExecutor<io.siddhi.core.util.snapshot.state.State>`

Copyright © 2020 WSO2. All rights reserved.