InternalAggregatingState (Flink : Runtime 1.20.3-cp2 API)

java.lang.Object
- org.apache.flink.runtime.state.v2.InternalKeyedState<K,ACC>
- - org.apache.flink.runtime.state.v2.InternalAggregatingState<K,IN,ACC,OUT>

Type Parameters:

K - The type of key the state is associated to.

IN - The type of the values that are added into the state.

ACC - TThe type of the accumulator (intermediate aggregation state).

OUT - The type of the values that are returned from the state.

All Implemented Interfaces:

org.apache.flink.api.common.state.v2.AggregatingState<IN,OUT>, org.apache.flink.api.common.state.v2.AppendingState<IN,OUT>, org.apache.flink.api.common.state.v2.MergingState<IN,OUT>, org.apache.flink.api.common.state.v2.State
```
public class InternalAggregatingState<K,IN,ACC,OUT>
extends InternalKeyedState<K,ACC>
implements org.apache.flink.api.common.state.v2.AggregatingState<IN,OUT>
```
The default implementation of AggregatingState, which delegates all async requests to StateRequestHandler.

Field Summary

Fields
Modifier and Type Field Description

protected org.apache.flink.api.common.functions.AggregateFunction<IN,ACC,OUT> aggregateFunction

Constructor Summary

Constructors
Constructor	Description
`InternalAggregatingState(StateRequestHandler stateRequestHandler, AggregatingStateDescriptor<IN,ACC,OUT> stateDescriptor)`	Creates a new InternalKeyedState with the given asyncExecutionController and stateDescriptor.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`org.apache.flink.api.common.state.v2.StateFuture<Void>`	`asyncAdd(IN value)`
`org.apache.flink.api.common.state.v2.StateFuture<OUT>`	`asyncGet()`

Methods inherited from class org.apache.flink.runtime.state.v2.InternalKeyedState
asyncClear, getStateDescriptor, getValueSerializer, handleRequest

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.api.common.state.v2.State
asyncClear

- Field Detail
  - aggregateFunction
```
protected final org.apache.flink.api.common.functions.AggregateFunction<IN,ACC,OUT> aggregateFunction
```
- Constructor Detail
  - InternalAggregatingState
```
public InternalAggregatingState(StateRequestHandler stateRequestHandler,
                                AggregatingStateDescriptor<IN,ACC,OUT> stateDescriptor)
```
    Creates a new InternalKeyedState with the given asyncExecutionController and stateDescriptor.
    
    Parameters:
    
    stateRequestHandler - The async request handler for handling all requests.
    
    stateDescriptor - The properties of the state.
- Method Detail
  - asyncGet
```
public org.apache.flink.api.common.state.v2.StateFuture<OUT> asyncGet()
```
    Specified by:
    
    asyncGet in interface org.apache.flink.api.common.state.v2.AppendingState<K,IN>
  - asyncAdd
```
public org.apache.flink.api.common.state.v2.StateFuture<Void> asyncAdd(IN value)
```
    Specified by:
    
    asyncAdd in interface org.apache.flink.api.common.state.v2.AppendingState<K,IN>