InternalListState (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.InternalListState<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,org.apache.flink.api.common.state.v2.StateIterator<V>>, org.apache.flink.api.common.state.v2.ListState<V>, org.apache.flink.api.common.state.v2.MergingState<V,org.apache.flink.api.common.state.v2.StateIterator<V>>, org.apache.flink.api.common.state.v2.State
```
public class InternalListState<K,V>
extends InternalKeyedState<K,V>
implements org.apache.flink.api.common.state.v2.ListState<V>
```
A default implementation of ListState which delegates all async requests to StateRequestHandler.

Constructor Summary

Constructors
Constructor Description

InternalListState(StateRequestHandler stateRequestHandler, ListStateDescriptor<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<Void>`	`asyncAddAll(List<V> values)`
`org.apache.flink.api.common.state.v2.StateFuture<org.apache.flink.api.common.state.v2.StateIterator<V>>`	`asyncGet()`
`org.apache.flink.api.common.state.v2.StateFuture<Void>`	`asyncUpdate(List<V> values)`

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

Constructor Detail

InternalListState

public InternalListState(StateRequestHandler stateRequestHandler,
                         ListStateDescriptor<V> stateDescriptor)

Method Detail
- asyncGet
```
public org.apache.flink.api.common.state.v2.StateFuture<org.apache.flink.api.common.state.v2.StateIterator<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>
- asyncUpdate
```
public org.apache.flink.api.common.state.v2.StateFuture<Void> asyncUpdate(List<V> values)
```
  Specified by:
  
  asyncUpdate in interface org.apache.flink.api.common.state.v2.ListState<K>
- asyncAddAll
```
public org.apache.flink.api.common.state.v2.StateFuture<Void> asyncAddAll(List<V> values)
```
  Specified by:
  
  asyncAddAll in interface org.apache.flink.api.common.state.v2.ListState<K>