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, ConfigurableStateBackend, DelegatingStateBackend, StateBackend

@Internal
public class ChangelogStateBackend
extends AbstractChangelogStateBackend
implements 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

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	Description
StateBackend	configure(ReadableConfig config, ClassLoader classLoader)	Creates a variant of the state backend that applies additional configuration parameters.
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, createKeyedStateBackend, createOperatorStateBackend, supportsAsyncKeyedStateBackend, supportsNoClaimRestoreMode, supportsSavepointFormat, useManagedMemory

Method Detail

configure

public StateBackend configure(ReadableConfig config,
                              ClassLoader classLoader)
                       throws IllegalConfigurationException

Description copied from interface: ConfigurableStateBackend

Creates a variant of the state backend that applies additional configuration parameters.

Settings that were directly done on the original state backend object in the application program typically have precedence over setting picked up from the configuration.

If no configuration is applied, or if the method directly applies configuration values to the (mutable) state backend object, this method may return the original state backend object. Otherwise it typically returns a modified copy.

Specified by:

configure in interface ConfigurableStateBackend

Parameters:

config - The configuration to pick the values from.

classLoader - The class loader that should be used to load the state backend.

Returns:

A reconfigured state backend.

Throws:

IllegalConfigurationException - Thrown if the configuration contained invalid entries.

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