Package org.apache.flink.state.rocksdb
Class StateHandleDownloadSpec
- java.lang.Object
-
- org.apache.flink.state.rocksdb.StateHandleDownloadSpec
-
public class StateHandleDownloadSpec extends Object
This class represents a download specification for the content of oneIncrementalRemoteKeyedStateHandle
to a targetPath
.
-
-
Constructor Summary
Constructors Constructor Description StateHandleDownloadSpec(IncrementalRemoteKeyedStateHandle stateHandle, Path downloadDestination)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description IncrementalLocalKeyedStateHandle
createLocalStateHandleForDownloadedState()
Path
getDownloadDestination()
IncrementalRemoteKeyedStateHandle
getStateHandle()
String
toString()
-
-
-
Constructor Detail
-
StateHandleDownloadSpec
public StateHandleDownloadSpec(IncrementalRemoteKeyedStateHandle stateHandle, Path downloadDestination)
-
-
Method Detail
-
getStateHandle
public IncrementalRemoteKeyedStateHandle getStateHandle()
-
getDownloadDestination
public Path getDownloadDestination()
-
createLocalStateHandleForDownloadedState
public IncrementalLocalKeyedStateHandle createLocalStateHandleForDownloadedState()
-
-