Package org.apache.flink.runtime.state.v2

Class InternalMapState<K,UK,V>

java.lang.Object

org.apache.flink.runtime.state.v2.InternalKeyedState<K,V>

org.apache.flink.runtime.state.v2.InternalMapState<K,UK,V>

Type Parameters:

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

UK - The type of user key of this state.

V - The type of values kept internally in state.

All Implemented Interfaces:

org.apache.flink.api.common.state.v2.MapState<UK,V>, org.apache.flink.api.common.state.v2.State

public class InternalMapState<K,UK,V>
extends InternalKeyedState<K,V>
implements org.apache.flink.api.common.state.v2.MapState<UK,V>

A default implementation of MapState which delegates all async requests to StateRequestHandler.

Constructor Summary

Constructors

Constructor	Description
InternalMapState(StateRequestHandler stateRequestHandler, MapStateDescriptor<UK,V> stateDescriptor)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.api.common.state.v2.StateFuture<Boolean>	asyncContains(UK key)
org.apache.flink.api.common.state.v2.StateFuture<org.apache.flink.api.common.state.v2.StateIterator<Map.Entry<UK,V>>>	asyncEntries()
org.apache.flink.api.common.state.v2.StateFuture<V>	asyncGet(UK key)
org.apache.flink.api.common.state.v2.StateFuture<Boolean>	asyncIsEmpty()
org.apache.flink.api.common.state.v2.StateFuture<org.apache.flink.api.common.state.v2.StateIterator<UK>>	asyncKeys()
org.apache.flink.api.common.state.v2.StateFuture<Void>	asyncPut(UK key, V value)
org.apache.flink.api.common.state.v2.StateFuture<Void>	asyncPutAll(Map<UK,V> map)
org.apache.flink.api.common.state.v2.StateFuture<Void>	asyncRemove(UK key)
org.apache.flink.api.common.state.v2.StateFuture<org.apache.flink.api.common.state.v2.StateIterator<V>>	asyncValues()

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

InternalMapState

public InternalMapState(StateRequestHandler stateRequestHandler,
                        MapStateDescriptor<UK,V> stateDescriptor)

Method Detail

asyncGet

public org.apache.flink.api.common.state.v2.StateFuture<V> asyncGet(UK key)

Specified by:

asyncGet in interface org.apache.flink.api.common.state.v2.MapState<K,UK>

asyncPut

public org.apache.flink.api.common.state.v2.StateFuture<Void> asyncPut(UK key,
                                                                       V value)

Specified by:

asyncPut in interface org.apache.flink.api.common.state.v2.MapState<K,UK>

asyncPutAll

public org.apache.flink.api.common.state.v2.StateFuture<Void> asyncPutAll(Map<UK,V> map)

Specified by:

asyncPutAll in interface org.apache.flink.api.common.state.v2.MapState<K,UK>

asyncRemove

public org.apache.flink.api.common.state.v2.StateFuture<Void> asyncRemove(UK key)

Specified by:

asyncRemove in interface org.apache.flink.api.common.state.v2.MapState<K,UK>

asyncContains

public org.apache.flink.api.common.state.v2.StateFuture<Boolean> asyncContains(UK key)

Specified by:

asyncContains in interface org.apache.flink.api.common.state.v2.MapState<K,UK>

asyncEntries

public org.apache.flink.api.common.state.v2.StateFuture<org.apache.flink.api.common.state.v2.StateIterator<Map.Entry<UK,V>>> asyncEntries()

Specified by:

asyncEntries in interface org.apache.flink.api.common.state.v2.MapState<K,UK>

asyncKeys

public org.apache.flink.api.common.state.v2.StateFuture<org.apache.flink.api.common.state.v2.StateIterator<UK>> asyncKeys()

Specified by:

asyncKeys in interface org.apache.flink.api.common.state.v2.MapState<K,UK>

asyncValues

public org.apache.flink.api.common.state.v2.StateFuture<org.apache.flink.api.common.state.v2.StateIterator<V>> asyncValues()

Specified by:

asyncValues in interface org.apache.flink.api.common.state.v2.MapState<K,UK>

asyncIsEmpty

public org.apache.flink.api.common.state.v2.StateFuture<Boolean> asyncIsEmpty()

Specified by:

asyncIsEmpty in interface org.apache.flink.api.common.state.v2.MapState<K,UK>