Package org.apache.flink.state.changelog

Class ChangelogStateBackend

java.lang.Object

org.apache.flink.state.changelog.AbstractChangelogStateBackend

org.apache.flink.state.changelog.ChangelogStateBackend

All Implemented Interfaces:

Serializable, org.apache.flink.runtime.state.ConfigurableStateBackend, org.apache.flink.runtime.state.delegate.DelegatingStateBackend, org.apache.flink.runtime.state.StateBackend

@Internal
public class ChangelogStateBackend
extends AbstractChangelogStateBackend
implements org.apache.flink.runtime.state.ConfigurableStateBackend

This state backend holds the working state in the underlying delegatedStateBackend, and forwards state changes to State Changelog.

See Also:

Serialized Form

Nested Class Summary

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

org.apache.flink.runtime.state.StateBackend.CustomInitializationMetrics, org.apache.flink.runtime.state.StateBackend.KeyedStateBackendParameters<K extends Object>, org.apache.flink.runtime.state.StateBackend.OperatorStateBackendParameters

Field Summary

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

delegatedStateBackend

Method Summary

Modifier and Type	Method	Description
org.apache.flink.runtime.state.StateBackend	configure(org.apache.flink.configuration.ReadableConfig config, ClassLoader classLoader)
protected <K> org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<K>	restore(org.apache.flink.runtime.execution.Environment env, String operatorIdentifier, org.apache.flink.runtime.state.KeyGroupRange keyGroupRange, org.apache.flink.runtime.state.ttl.TtlTimeProvider ttlTimeProvider, org.apache.flink.metrics.MetricGroup metricGroup, Collection<org.apache.flink.runtime.state.changelog.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, createKeyedStateBackend, createOperatorStateBackend, supportsAsyncKeyedStateBackend, supportsNoClaimRestoreMode, supportsSavepointFormat, useManagedMemory

Method Detail

configure

public org.apache.flink.runtime.state.StateBackend configure(org.apache.flink.configuration.ReadableConfig config,
                                                             ClassLoader classLoader)
                                                      throws org.apache.flink.configuration.IllegalConfigurationException

Specified by:

configure in interface org.apache.flink.runtime.state.ConfigurableStateBackend

Throws:

org.apache.flink.configuration.IllegalConfigurationException

restore

protected <K> org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<K> restore(org.apache.flink.runtime.execution.Environment env,
                                                                                        String operatorIdentifier,
                                                                                        org.apache.flink.runtime.state.KeyGroupRange keyGroupRange,
                                                                                        org.apache.flink.runtime.state.ttl.TtlTimeProvider ttlTimeProvider,
                                                                                        org.apache.flink.metrics.MetricGroup metricGroup,
                                                                                        Collection<org.apache.flink.runtime.state.changelog.ChangelogStateBackendHandle> stateBackendHandles,
                                                                                        ChangelogBackendRestoreOperation.BaseBackendBuilder<K> baseBackendBuilder)
                                                                                 throws Exception

Specified by:

restore in class AbstractChangelogStateBackend

Throws:

Exception