Modifier and Type | Method and Description |
---|---|
Map<StateHandleID,StreamStateHandle> |
RocksDBStateUploader.uploadFilesToCheckpointFs(Map<StateHandleID,Path> files,
CheckpointStreamFactory checkpointStreamFactory,
CheckpointedStateScope stateScope,
CloseableRegistry closeableRegistry,
CloseableRegistry tmpResourcesRegistry)
Upload all the files to checkpoint fileSystem using specified number of threads.
|
Modifier and Type | Method and Description |
---|---|
static CheckpointedStateScope |
CheckpointedStateScope.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static CheckpointedStateScope[] |
CheckpointedStateScope.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
boolean |
CheckpointStreamFactory.canFastDuplicate(StreamStateHandle stateHandle,
CheckpointedStateScope scope)
Tells if we can duplicate the given
StreamStateHandle into the path corresponding to
the given CheckpointedStateScope . |
CheckpointStateOutputStream |
CheckpointStreamFactory.createCheckpointStateOutputStream(CheckpointedStateScope scope)
Creates an new
CheckpointStateOutputStream . |
static CheckpointStreamWithResultProvider |
CheckpointStreamWithResultProvider.createDuplicatingStream(long checkpointId,
CheckpointedStateScope checkpointedStateScope,
CheckpointStreamFactory primaryStreamFactory,
LocalRecoveryDirectoryProvider secondaryStreamDirProvider) |
static CheckpointStreamWithResultProvider |
CheckpointStreamWithResultProvider.createSimpleStream(CheckpointedStateScope checkpointedStateScope,
CheckpointStreamFactory primaryStreamFactory) |
List<StreamStateHandle> |
CheckpointStreamFactory.duplicate(List<StreamStateHandle> stateHandles,
CheckpointedStateScope scope)
Duplicates
StreamStateHandle into the path corresponding to * the given CheckpointedStateScope . |
Modifier and Type | Method and Description |
---|---|
boolean |
FsCheckpointStreamFactory.canFastDuplicate(StreamStateHandle stateHandle,
CheckpointedStateScope scope) |
FsCheckpointStreamFactory.FsCheckpointStateOutputStream |
FsCheckpointStreamFactory.createCheckpointStateOutputStream(CheckpointedStateScope scope) |
List<StreamStateHandle> |
FsCheckpointStreamFactory.duplicate(List<StreamStateHandle> stateHandles,
CheckpointedStateScope scope) |
Modifier and Type | Method and Description |
---|---|
boolean |
MemCheckpointStreamFactory.canFastDuplicate(StreamStateHandle stateHandle,
CheckpointedStateScope scope) |
CheckpointStateOutputStream |
MemCheckpointStreamFactory.createCheckpointStateOutputStream(CheckpointedStateScope scope) |
List<StreamStateHandle> |
MemCheckpointStreamFactory.duplicate(List<StreamStateHandle> stateHandles,
CheckpointedStateScope scope) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.