Uses of Class
org.apache.flink.state.forst.ForStPathContainer
-
Packages that use ForStPathContainer Package Description org.apache.flink.state.forst org.apache.flink.state.forst.datatransfer -
-
Uses of ForStPathContainer in org.apache.flink.state.forst
Methods in org.apache.flink.state.forst that return ForStPathContainer Modifier and Type Method Description static ForStPathContainerForStPathContainer. empty()ForStPathContainerForStResourceContainer. getPathContainer()static ForStPathContainerForStPathContainer. of(org.apache.flink.core.fs.Path localJobPath, org.apache.flink.core.fs.Path localBasePath, org.apache.flink.core.fs.Path remoteJobPath, org.apache.flink.core.fs.Path remoteBasePath)static ForStPathContainerForStPathContainer. ofLocal(org.apache.flink.core.fs.Path localJobPath, org.apache.flink.core.fs.Path localBasePath)Constructors in org.apache.flink.state.forst with parameters of type ForStPathContainer Constructor Description ForStResourceContainer(org.apache.flink.configuration.ReadableConfig configuration, ForStOptionsFactory optionsFactory, org.apache.flink.runtime.memory.OpaqueMemoryResource<org.apache.flink.state.forst.ForStSharedResources> sharedResources, ForStPathContainer pathContainer, org.apache.flink.core.execution.RecoveryClaimMode claimMode, org.apache.flink.runtime.state.CheckpointStorageAccess checkpointStorageAccess, org.apache.flink.metrics.MetricGroup metricGroup, boolean enableStatistics) -
Uses of ForStPathContainer in org.apache.flink.state.forst.datatransfer
Methods in org.apache.flink.state.forst.datatransfer with parameters of type ForStPathContainer Modifier and Type Method Description static DataTransferStrategyDataTransferStrategyBuilder. buildForRestore(ForStFlinkFileSystem forStFlinkFileSystem, ForStPathContainer forStPathContainer, Collection<StateHandleTransferSpec> specs, org.apache.flink.core.execution.RecoveryClaimMode recoveryClaimMode)voidForStStateDataTransfer. transferAllStateDataToDirectory(ForStPathContainer forStPathContainer, Collection<StateHandleTransferSpec> transferSpecs, org.apache.flink.core.fs.CloseableRegistry closeableRegistry, org.apache.flink.core.execution.RecoveryClaimMode recoveryClaimMode)Transfer all state data to the target directory, as specified in the transfer requests.
-