public class ProxyOperatorStateBackend extends Object implements org.apache.flink.runtime.state.OperatorStateBackend
OperatorStateBackend
for the wrapped Operator.Constructor and Description |
---|
ProxyOperatorStateBackend(org.apache.flink.runtime.state.OperatorStateBackend wrappedBackend,
StateNamePrefix stateNamePrefix) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
dispose() |
<K,V> org.apache.flink.api.common.state.BroadcastState<K,V> |
getBroadcastState(org.apache.flink.api.common.state.MapStateDescriptor<K,V> stateDescriptor) |
<S> org.apache.flink.api.common.state.ListState<S> |
getListState(org.apache.flink.api.common.state.ListStateDescriptor<S> stateDescriptor) |
Set<String> |
getRegisteredBroadcastStateNames() |
Set<String> |
getRegisteredStateNames() |
<S> org.apache.flink.api.common.state.ListState<S> |
getUnionListState(org.apache.flink.api.common.state.ListStateDescriptor<S> stateDescriptor) |
RunnableFuture<org.apache.flink.runtime.state.SnapshotResult<org.apache.flink.runtime.state.OperatorStateHandle>> |
snapshot(long checkpointId,
long timestamp,
org.apache.flink.runtime.state.CheckpointStreamFactory streamFactory,
org.apache.flink.runtime.checkpoint.CheckpointOptions checkpointOptions) |
public ProxyOperatorStateBackend(org.apache.flink.runtime.state.OperatorStateBackend wrappedBackend, StateNamePrefix stateNamePrefix)
public <K,V> org.apache.flink.api.common.state.BroadcastState<K,V> getBroadcastState(org.apache.flink.api.common.state.MapStateDescriptor<K,V> stateDescriptor) throws Exception
getBroadcastState
in interface org.apache.flink.api.common.state.OperatorStateStore
Exception
public <S> org.apache.flink.api.common.state.ListState<S> getListState(org.apache.flink.api.common.state.ListStateDescriptor<S> stateDescriptor) throws Exception
getListState
in interface org.apache.flink.api.common.state.OperatorStateStore
Exception
public <S> org.apache.flink.api.common.state.ListState<S> getUnionListState(org.apache.flink.api.common.state.ListStateDescriptor<S> stateDescriptor) throws Exception
getUnionListState
in interface org.apache.flink.api.common.state.OperatorStateStore
Exception
public Set<String> getRegisteredStateNames()
getRegisteredStateNames
in interface org.apache.flink.api.common.state.OperatorStateStore
public Set<String> getRegisteredBroadcastStateNames()
getRegisteredBroadcastStateNames
in interface org.apache.flink.api.common.state.OperatorStateStore
public void dispose()
dispose
in interface org.apache.flink.runtime.state.OperatorStateBackend
dispose
in interface org.apache.flink.util.Disposable
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
@Nonnull public RunnableFuture<org.apache.flink.runtime.state.SnapshotResult<org.apache.flink.runtime.state.OperatorStateHandle>> 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.OperatorStateHandle>>
Exception
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.