Package org.apache.flink.state.forst.datatransfer

Class DataTransferStrategy

  • Direct Known Subclasses:
    CopyDataTransferStrategy
    public abstract class DataTransferStrategy
extends Object
    Base class for data transfer strategy, called by ForSt to transfer data between Checkpoint and DB.

    • Field Summary

      Fields 
      Modifier and Type Field Description
      protected org.apache.flink.core.fs.FileSystem dbFileSystem  
      protected static org.slf4j.Logger LOG  

    • Constructor Summary

      Constructors 
      Modifier Constructor Description
      protected DataTransferStrategy​(org.apache.flink.core.fs.FileSystem dbFileSystem)  

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      abstract void transferFromCheckpoint​(org.apache.flink.runtime.state.StreamStateHandle sourceHandle, org.apache.flink.core.fs.Path targetPath, org.apache.flink.core.fs.CloseableRegistry closeableRegistry)  
      abstract org.apache.flink.runtime.state.IncrementalKeyedStateHandle.HandleAndLocalPath transferToCheckpoint​(org.apache.flink.core.fs.Path dbFilePath, long maxTransferBytes, org.apache.flink.runtime.state.CheckpointStreamFactory checkpointStreamFactory, org.apache.flink.runtime.state.CheckpointedStateScope stateScope, org.apache.flink.core.fs.CloseableRegistry closeableRegistry, org.apache.flink.core.fs.CloseableRegistry tmpResourcesRegistry)  

    • Field Detail

      • LOG

        protected static final org.slf4j.Logger LOG

      • dbFileSystem

        @Nonnull
protected final org.apache.flink.core.fs.FileSystem dbFileSystem

    • Constructor Detail

      • DataTransferStrategy

        protected DataTransferStrategy​(@Nonnull
                               org.apache.flink.core.fs.FileSystem dbFileSystem)

    • Method Detail

      • transferToCheckpoint

        public abstract org.apache.flink.runtime.state.IncrementalKeyedStateHandle.HandleAndLocalPath transferToCheckpoint​(org.apache.flink.core.fs.Path dbFilePath,
                                                                                                                   long maxTransferBytes,
                                                                                                                   org.apache.flink.runtime.state.CheckpointStreamFactory checkpointStreamFactory,
                                                                                                                   org.apache.flink.runtime.state.CheckpointedStateScope stateScope,
                                                                                                                   org.apache.flink.core.fs.CloseableRegistry closeableRegistry,
                                                                                                                   org.apache.flink.core.fs.CloseableRegistry tmpResourcesRegistry)
                                                                                                            throws IOException
        Throws:
        IOException

      • transferFromCheckpoint

        public abstract void transferFromCheckpoint​(org.apache.flink.runtime.state.StreamStateHandle sourceHandle,
                                            org.apache.flink.core.fs.Path targetPath,
                                            org.apache.flink.core.fs.CloseableRegistry closeableRegistry)
                                     throws IOException
        Throws:
        IOException