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

Class DataTransferStrategyBuilder

java.lang.Object

org.apache.flink.state.forst.datatransfer.DataTransferStrategyBuilder

public class DataTransferStrategyBuilder
extends Object

Builder for DataTransferStrategy for snapshots.

Constructor Summary

Constructors

Constructor	Description
DataTransferStrategyBuilder()

Method Summary

Modifier and Type	Method	Description
static DataTransferStrategy	buildForRestore(ForStFlinkFileSystem forStFlinkFileSystem, Collection<StateHandleTransferSpec> specs, org.apache.flink.core.execution.RecoveryClaimMode recoveryClaimMode)
static DataTransferStrategy	buildForSnapshot(org.apache.flink.runtime.checkpoint.SnapshotType.SharingFilesStrategy sharingFilesStrategy, ForStFlinkFileSystem forStFlinkFileSystem, org.apache.flink.runtime.state.CheckpointStreamFactory checkpointStreamFactory, boolean forceCopy)

Methods inherited from class java.lang.Object

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

Constructor Detail

DataTransferStrategyBuilder

public DataTransferStrategyBuilder()

Method Detail

buildForSnapshot

public static DataTransferStrategy buildForSnapshot(org.apache.flink.runtime.checkpoint.SnapshotType.SharingFilesStrategy sharingFilesStrategy,
                                                    @Nullable
                                                    ForStFlinkFileSystem forStFlinkFileSystem,
                                                    @Nullable
                                                    org.apache.flink.runtime.state.CheckpointStreamFactory checkpointStreamFactory,
                                                    boolean forceCopy)

buildForRestore

public static DataTransferStrategy buildForRestore(@Nullable
                                                   ForStFlinkFileSystem forStFlinkFileSystem,
                                                   Collection<StateHandleTransferSpec> specs,
                                                   org.apache.flink.core.execution.RecoveryClaimMode recoveryClaimMode)