Package org.apache.flink.state.changelog

Class AbstractChangelogStateBackend

  • All Implemented Interfaces:
    Serializable, org.apache.flink.runtime.state.delegate.DelegatingStateBackend, org.apache.flink.runtime.state.StateBackend
    Direct Known Subclasses:
    ChangelogStateBackend, DeactivatedChangelogStateBackend
    @Internal
public abstract class AbstractChangelogStateBackend
extends Object
implements org.apache.flink.runtime.state.delegate.DelegatingStateBackend, org.apache.flink.runtime.state.StateBackend
    An abstract base implementation of the StateBackend interface whose subclasses use delegatedStateBackend and State changes to restore.
    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 
      Modifier and Type Field Description
      protected org.apache.flink.runtime.state.StateBackend delegatedStateBackend  

    • Method Summary

      All Methods Instance Methods Abstract Methods Concrete Methods 
      Modifier and Type Method Description
      <K> org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<K> createKeyedStateBackend​(org.apache.flink.runtime.state.StateBackend.KeyedStateBackendParameters<K> parameters)  
      org.apache.flink.runtime.state.OperatorStateBackend createOperatorStateBackend​(org.apache.flink.runtime.state.StateBackend.OperatorStateBackendParameters parameters)  
      org.apache.flink.runtime.state.StateBackend getDelegatedStateBackend()  
      protected abstract <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)  
      boolean supportsSavepointFormat​(org.apache.flink.core.execution.SavepointFormatType formatType)  
      boolean useManagedMemory()  

      • 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

    • Field Detail

      • delegatedStateBackend

        protected final org.apache.flink.runtime.state.StateBackend delegatedStateBackend

    • Method Detail

      • createKeyedStateBackend

        public <K> org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<K> createKeyedStateBackend​(org.apache.flink.runtime.state.StateBackend.KeyedStateBackendParameters<K> parameters)
                                                                                              throws Exception
        Specified by:
        createKeyedStateBackend in interface org.apache.flink.runtime.state.StateBackend
        Throws:
        Exception

      • createOperatorStateBackend

        public org.apache.flink.runtime.state.OperatorStateBackend createOperatorStateBackend​(org.apache.flink.runtime.state.StateBackend.OperatorStateBackendParameters parameters)
                                                                               throws Exception
        Specified by:
        createOperatorStateBackend in interface org.apache.flink.runtime.state.StateBackend
        Throws:
        Exception

      • useManagedMemory

        public boolean useManagedMemory()
        Specified by:
        useManagedMemory in interface org.apache.flink.runtime.state.StateBackend

      • getDelegatedStateBackend

        public org.apache.flink.runtime.state.StateBackend getDelegatedStateBackend()
        Specified by:
        getDelegatedStateBackend in interface org.apache.flink.runtime.state.delegate.DelegatingStateBackend

      • supportsSavepointFormat

        public boolean supportsSavepointFormat​(org.apache.flink.core.execution.SavepointFormatType formatType)
        Specified by:
        supportsSavepointFormat in interface org.apache.flink.runtime.state.StateBackend

      • restore

        protected abstract <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
        Throws:
        Exception