Uses of Class
org.apache.flink.state.forst.fs.ForStFlinkFileSystem
-
Packages that use ForStFlinkFileSystem Package Description org.apache.flink.state.forst org.apache.flink.state.forst.datatransfer org.apache.flink.state.forst.fs -
-
Uses of ForStFlinkFileSystem in org.apache.flink.state.forst
Methods in org.apache.flink.state.forst that return ForStFlinkFileSystem Modifier and Type Method Description ForStFlinkFileSystemForStResourceContainer. getFileSystem() -
Uses of ForStFlinkFileSystem in org.apache.flink.state.forst.datatransfer
Methods in org.apache.flink.state.forst.datatransfer with parameters of type ForStFlinkFileSystem Modifier and Type Method Description static DataTransferStrategyDataTransferStrategyBuilder. buildForRestore(ForStFlinkFileSystem forStFlinkFileSystem, ForStPathContainer forStPathContainer, Collection<StateHandleTransferSpec> specs, org.apache.flink.core.execution.RecoveryClaimMode recoveryClaimMode)static DataTransferStrategyDataTransferStrategyBuilder. buildForSnapshot(org.apache.flink.runtime.checkpoint.SnapshotType.SharingFilesStrategy sharingFilesStrategy, ForStFlinkFileSystem forStFlinkFileSystem, org.apache.flink.runtime.state.CheckpointStreamFactory checkpointStreamFactory, boolean forceCopy)Constructors in org.apache.flink.state.forst.datatransfer with parameters of type ForStFlinkFileSystem Constructor Description ForStStateDataTransfer(int threadNum, ForStFlinkFileSystem forStFs) -
Uses of ForStFlinkFileSystem in org.apache.flink.state.forst.fs
Subclasses of ForStFlinkFileSystem in org.apache.flink.state.forst.fs Modifier and Type Class Description classForStFileSystemTrackingCreatedDirDecoratorA decorator ofForStFlinkFileSystemto adapt ForSt to the underlying FileSystems which are implemented with incomplete mkdir(), i.e., such FileSystem implementation does not actually create the directory when mkdir() completes.Methods in org.apache.flink.state.forst.fs that return ForStFlinkFileSystem Modifier and Type Method Description static ForStFlinkFileSystemForStFlinkFileSystem. get(URI uri)Returns a reference to theFileSysteminstance for accessing the file system identified by the givenURI.static ForStFlinkFileSystemForStFlinkFileSystem. get(URI uri, org.apache.flink.core.fs.Path localBase, FileBasedCache fileBasedCache)static ForStFlinkFileSystemForStFileSystemUtils. tryDecorate(ForStFlinkFileSystem fileSystem)Methods in org.apache.flink.state.forst.fs with parameters of type ForStFlinkFileSystem Modifier and Type Method Description static ForStFlinkFileSystemForStFileSystemUtils. tryDecorate(ForStFlinkFileSystem fileSystem)Constructors in org.apache.flink.state.forst.fs with parameters of type ForStFlinkFileSystem Constructor Description ForStFlinkFileSystem(ForStFlinkFileSystem forStFlinkFileSystem)StringifiedForStFileSystem(ForStFlinkFileSystem fileSystem)
-