InternalReducingState (Flink : Runtime 1.20.3-cp2 API)

java.lang.Object
- org.apache.flink.runtime.state.v2.InternalKeyedState<K,V>
- - org.apache.flink.runtime.state.v2.InternalReducingState<K,V>

Type Parameters:

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

V - The type of values kept internally in state.

All Implemented Interfaces:

org.apache.flink.api.common.state.v2.AppendingState<V,V>, org.apache.flink.api.common.state.v2.MergingState<V,V>, org.apache.flink.api.common.state.v2.ReducingState<V>, org.apache.flink.api.common.state.v2.State
```
public class InternalReducingState<K,V>
extends InternalKeyedState<K,V>
implements org.apache.flink.api.common.state.v2.ReducingState<V>
```
A default implementation of ReducingState which delegates all async requests to StateRequestHandler.

Field Summary

Fields
Modifier and Type Field Description

protected org.apache.flink.api.common.functions.ReduceFunction<V> reduceFunction

Constructor Summary

Constructors
Constructor Description

InternalReducingState(StateRequestHandler stateRequestHandler, ReducingStateDescriptor<V> stateDescriptor)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`org.apache.flink.api.common.state.v2.StateFuture<Void>`	`asyncAdd(V value)`
`org.apache.flink.api.common.state.v2.StateFuture<V>`	`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

reduceFunction

protected final org.apache.flink.api.common.functions.ReduceFunction<V> reduceFunction

Constructor Detail

InternalReducingState

public InternalReducingState(StateRequestHandler stateRequestHandler,
                             ReducingStateDescriptor<V> stateDescriptor)

Method Detail
- asyncGet
```
public org.apache.flink.api.common.state.v2.StateFuture<V> asyncGet()
```
  Specified by:
  
  asyncGet in interface org.apache.flink.api.common.state.v2.AppendingState<K,V>
- asyncAdd
```
public org.apache.flink.api.common.state.v2.StateFuture<Void> asyncAdd(V value)
```
  Specified by:
  
  asyncAdd in interface org.apache.flink.api.common.state.v2.AppendingState<K,V>