Uses of Class
org.apache.flink.state.forst.StateHandleTransferSpec
-
Packages that use StateHandleTransferSpec Package Description org.apache.flink.state.forst.datatransfer org.apache.flink.state.forst.restore -
-
Uses of StateHandleTransferSpec in org.apache.flink.state.forst.datatransfer
Method parameters in org.apache.flink.state.forst.datatransfer with type arguments of type StateHandleTransferSpec 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. -
Uses of StateHandleTransferSpec in org.apache.flink.state.forst.restore
Method parameters in org.apache.flink.state.forst.restore with type arguments of type StateHandleTransferSpec Modifier and Type Method Description voidForStIncrementalRestoreOperation. mergeStateHandlesWithClipAndIngest(List<StateHandleTransferSpec> keyedStateHandles, byte[] startKeyGroupPrefixBytes, byte[] stopKeyGroupPrefixBytes)Restores the base DB by merging multiple state handles into one.
-