org.apache.flink.runtime.state.delegate

Interface DelegatingStateBackend

All Superinterfaces:

Serializable, StateBackend

All Known Implementing Classes:

AbstractChangelogStateBackend, ChangelogStateBackend, DeactivatedChangelogStateBackend

@Internal
public interface DelegatingStateBackend
extends StateBackend

An interface to delegate state backend.

As its name, it should include a state backend to delegate.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.runtime.state.StateBackend

StateBackend.CustomInitializationMetrics, StateBackend.KeyedStateBackendParameters<K>, StateBackend.OperatorStateBackendParameters

Method Summary

Modifier and Type	Method and Description
StateBackend	getDelegatedStateBackend()
default String	getName() Return the name of this backend, default is simple class name.

Methods inherited from interface org.apache.flink.runtime.state.StateBackend

createAsyncKeyedStateBackend, createKeyedStateBackend, createOperatorStateBackend, supportsAsyncKeyedStateBackend, supportsNoClaimRestoreMode, supportsSavepointFormat, useManagedMemory

Method Detail

getDelegatedStateBackend

StateBackend getDelegatedStateBackend()

getName

default String getName()

Description copied from interface: StateBackend

Return the name of this backend, default is simple class name. DelegatingStateBackend may return the simple class name of the delegated backend.

Specified by:

getName in interface StateBackend