org.apache.flink.state.changelog

Class DeactivatedChangelogStateBackend

java.lang.Object

org.apache.flink.state.changelog.AbstractChangelogStateBackend

org.apache.flink.state.changelog.DeactivatedChangelogStateBackend

All Implemented Interfaces:

Serializable, DelegatingStateBackend, StateBackend

@Internal
public class DeactivatedChangelogStateBackend
extends AbstractChangelogStateBackend

This state backend use delegatedStateBackend and State changes to restore to the delegatedStateBackend in which switching Changelog from enabled to disabled.

See Also:

Serialized Form

Nested Class Summary

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

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

Field Summary

Fields inherited from class org.apache.flink.state.changelog.AbstractChangelogStateBackend

delegatedStateBackend

Method Summary

Modifier and Type	Method and Description
protected <K> CheckpointableKeyedStateBackend<K>	restore(Environment env, String operatorIdentifier, KeyGroupRange keyGroupRange, TtlTimeProvider ttlTimeProvider, MetricGroup metricGroup, Collection<ChangelogStateBackendHandle> stateBackendHandles, ChangelogBackendRestoreOperation.BaseBackendBuilder<K> baseBackendBuilder)

Methods inherited from class org.apache.flink.state.changelog.AbstractChangelogStateBackend

createKeyedStateBackend, createOperatorStateBackend, getDelegatedStateBackend, supportsSavepointFormat, useManagedMemory

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.runtime.state.delegate.DelegatingStateBackend

getName

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

createAsyncKeyedStateBackend, supportsAsyncKeyedStateBackend, supportsNoClaimRestoreMode

Method Detail

restore

protected <K> CheckpointableKeyedStateBackend<K> restore(Environment env,
                                                         String operatorIdentifier,
                                                         KeyGroupRange keyGroupRange,
                                                         TtlTimeProvider ttlTimeProvider,
                                                         MetricGroup metricGroup,
                                                         Collection<ChangelogStateBackendHandle> stateBackendHandles,
                                                         ChangelogBackendRestoreOperation.BaseBackendBuilder<K> baseBackendBuilder)
                                                  throws Exception

Specified by:

restore in class AbstractChangelogStateBackend

Throws:

Exception