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

Class CopyDataTransferStrategy

java.lang.Object

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

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

Direct Known Subclasses:

ReusableDataTransferStrategy

public class CopyDataTransferStrategy
extends DataTransferStrategy

Data transfer strategy for ForSt DB without a remote DB path. It always copies the file to/from checkpoint storage when transferring data.

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

Specified by:

transferToCheckpoint in class DataTransferStrategy

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

Specified by:

transferFromCheckpoint in class DataTransferStrategy

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object