public class ProxyKeyedStateBackend<K> extends Object implements org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<K>
KeyedStateBackend
for the wrapped operators.Constructor and Description |
---|
ProxyKeyedStateBackend(org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<K> wrappedBackend,
StateNamePrefix stateNamePrefix) |
Modifier and Type | Method and Description |
---|---|
<N,S extends org.apache.flink.api.common.state.State,T> |
applyToAllKeys(N namespace,
org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer,
org.apache.flink.api.common.state.StateDescriptor<S,T> stateDescriptor,
org.apache.flink.runtime.state.KeyedStateFunction<K,S> function) |
void |
close() |
<T extends org.apache.flink.runtime.state.heap.HeapPriorityQueueElement & org.apache.flink.runtime.state.PriorityComparable<? super T> & org.apache.flink.runtime.state.Keyed<?>> |
create(String stateName,
org.apache.flink.api.common.typeutils.TypeSerializer<T> byteOrderedElementSerializer) |
protected <S extends org.apache.flink.api.common.state.State,T> |
createNewDescriptor(org.apache.flink.api.common.state.StateDescriptor<S,T> descriptor) |
<N,SV,SEV,S extends org.apache.flink.api.common.state.State,IS extends S> |
createOrUpdateInternalState(org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer,
org.apache.flink.api.common.state.StateDescriptor<S,SV> stateDesc,
org.apache.flink.runtime.state.StateSnapshotTransformer.StateSnapshotTransformFactory<SEV> snapshotTransformFactory) |
boolean |
deregisterKeySelectionListener(org.apache.flink.runtime.state.KeyedStateBackend.KeySelectionListener<K> listener) |
void |
dispose() |
K |
getCurrentKey() |
org.apache.flink.runtime.state.KeyGroupRange |
getKeyGroupRange() |
<N> java.util.stream.Stream<K> |
getKeys(String state,
N namespace) |
<N> java.util.stream.Stream<org.apache.flink.api.java.tuple.Tuple2<K,N>> |
getKeysAndNamespaces(String state) |
org.apache.flink.api.common.typeutils.TypeSerializer<K> |
getKeySerializer() |
<N,S extends org.apache.flink.api.common.state.State,T> |
getOrCreateKeyedState(org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer,
org.apache.flink.api.common.state.StateDescriptor<S,T> stateDescriptor) |
<N,S extends org.apache.flink.api.common.state.State> |
getPartitionedState(N namespace,
org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer,
org.apache.flink.api.common.state.StateDescriptor<S,?> stateDescriptor) |
void |
registerKeySelectionListener(org.apache.flink.runtime.state.KeyedStateBackend.KeySelectionListener<K> listener) |
org.apache.flink.runtime.state.SavepointResources<K> |
savepoint() |
void |
setCurrentKey(K newKey) |
RunnableFuture<org.apache.flink.runtime.state.SnapshotResult<org.apache.flink.runtime.state.KeyedStateHandle>> |
snapshot(long checkpointId,
long timestamp,
org.apache.flink.runtime.state.CheckpointStreamFactory streamFactory,
org.apache.flink.runtime.checkpoint.CheckpointOptions checkpointOptions) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isSafeToReuseKVState, isStateImmutableInStateBackend
public ProxyKeyedStateBackend(org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<K> wrappedBackend, StateNamePrefix stateNamePrefix)
public void setCurrentKey(K newKey)
setCurrentKey
in interface org.apache.flink.runtime.state.KeyedStateBackend<K>
public K getCurrentKey()
getCurrentKey
in interface org.apache.flink.runtime.state.KeyedStateBackend<K>
public org.apache.flink.api.common.typeutils.TypeSerializer<K> getKeySerializer()
getKeySerializer
in interface org.apache.flink.runtime.state.KeyedStateBackend<K>
public <N,S extends org.apache.flink.api.common.state.State,T> void applyToAllKeys(N namespace, org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer, org.apache.flink.api.common.state.StateDescriptor<S,T> stateDescriptor, org.apache.flink.runtime.state.KeyedStateFunction<K,S> function) throws Exception
public <N> java.util.stream.Stream<K> getKeys(String state, N namespace)
getKeys
in interface org.apache.flink.runtime.state.KeyedStateBackend<K>
public <N> java.util.stream.Stream<org.apache.flink.api.java.tuple.Tuple2<K,N>> getKeysAndNamespaces(String state)
getKeysAndNamespaces
in interface org.apache.flink.runtime.state.KeyedStateBackend<K>
public <N,S extends org.apache.flink.api.common.state.State,T> S getOrCreateKeyedState(org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer, org.apache.flink.api.common.state.StateDescriptor<S,T> stateDescriptor) throws Exception
public <N,S extends org.apache.flink.api.common.state.State> S getPartitionedState(N namespace, org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer, org.apache.flink.api.common.state.StateDescriptor<S,?> stateDescriptor) throws Exception
public void registerKeySelectionListener(org.apache.flink.runtime.state.KeyedStateBackend.KeySelectionListener<K> listener)
registerKeySelectionListener
in interface org.apache.flink.runtime.state.KeyedStateBackend<K>
public boolean deregisterKeySelectionListener(org.apache.flink.runtime.state.KeyedStateBackend.KeySelectionListener<K> listener)
deregisterKeySelectionListener
in interface org.apache.flink.runtime.state.KeyedStateBackend<K>
@Nonnull public <N,SV,SEV,S extends org.apache.flink.api.common.state.State,IS extends S> IS createOrUpdateInternalState(@Nonnull org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer, @Nonnull org.apache.flink.api.common.state.StateDescriptor<S,SV> stateDesc, @Nonnull org.apache.flink.runtime.state.StateSnapshotTransformer.StateSnapshotTransformFactory<SEV> snapshotTransformFactory) throws Exception
createOrUpdateInternalState
in interface org.apache.flink.runtime.state.KeyedStateFactory
Exception
protected <S extends org.apache.flink.api.common.state.State,T> org.apache.flink.api.common.state.StateDescriptor<S,T> createNewDescriptor(org.apache.flink.api.common.state.StateDescriptor<S,T> descriptor)
public org.apache.flink.runtime.state.KeyGroupRange getKeyGroupRange()
getKeyGroupRange
in interface org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<K>
@Nonnull public org.apache.flink.runtime.state.SavepointResources<K> savepoint() throws Exception
public void dispose()
dispose
in interface org.apache.flink.runtime.state.KeyedStateBackend<K>
dispose
in interface org.apache.flink.util.Disposable
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
@Nonnull public <T extends org.apache.flink.runtime.state.heap.HeapPriorityQueueElement & org.apache.flink.runtime.state.PriorityComparable<? super T> & org.apache.flink.runtime.state.Keyed<?>> org.apache.flink.runtime.state.KeyGroupedInternalPriorityQueue<T> create(@Nonnull String stateName, @Nonnull org.apache.flink.api.common.typeutils.TypeSerializer<T> byteOrderedElementSerializer)
create
in interface org.apache.flink.runtime.state.PriorityQueueSetFactory
@Nonnull public RunnableFuture<org.apache.flink.runtime.state.SnapshotResult<org.apache.flink.runtime.state.KeyedStateHandle>> snapshot(long checkpointId, long timestamp, @Nonnull org.apache.flink.runtime.state.CheckpointStreamFactory streamFactory, @Nonnull org.apache.flink.runtime.checkpoint.CheckpointOptions checkpointOptions) throws Exception
snapshot
in interface org.apache.flink.runtime.state.Snapshotable<org.apache.flink.runtime.state.SnapshotResult<org.apache.flink.runtime.state.KeyedStateHandle>>
Exception
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.