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

Class ReusableDataTransferStrategy

java.lang.Object

org.apache.flink.state.forst.datatransfer.DataTransferStrategy

org.apache.flink.state.forst.datatransfer.CopyDataTransferStrategy

org.apache.flink.state.forst.datatransfer.ReusableDataTransferStrategy

public class ReusableDataTransferStrategy
extends CopyDataTransferStrategy

Data transfer strategy for ForSt DB with a remote DB path. When transferring data between Checkpoint and DB, this strategy MAY reuse the file from Checkpoint storage.

Field Summary

Fields inherited from class org.apache.flink.state.forst.datatransfer.DataTransferStrategy

dbFileSystem, LOG

Method Summary

Modifier and Type	Method	Description
String	toString()
void	transferFromCheckpoint(org.apache.flink.runtime.state.StreamStateHandle sourceHandle, org.apache.flink.core.fs.Path targetPath, org.apache.flink.core.fs.CloseableRegistry closeableRegistry)
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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

transferToCheckpoint

public 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

Overrides:

transferToCheckpoint in class CopyDataTransferStrategy

Throws:

IOException

transferFromCheckpoint

public 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

Overrides:

transferFromCheckpoint in class CopyDataTransferStrategy

Throws:

IOException

toString

public String toString()

Overrides:

toString in class CopyDataTransferStrategy