Package | Description |
---|---|
org.apache.flink.runtime.state | |
org.apache.flink.runtime.state.filesystem | |
org.apache.flink.runtime.state.memory |
Modifier and Type | Class and Description |
---|---|
class |
NotDuplicatingCheckpointStateToolset
An empty implementation of
CheckpointStateToolset . |
Modifier and Type | Method and Description |
---|---|
CheckpointStateToolset |
CheckpointStorageWorkerView.createTaskOwnedCheckpointStateToolset()
A complementary method to
CheckpointStorageWorkerView.createTaskOwnedStateStream() . |
Modifier and Type | Class and Description |
---|---|
class |
FsCheckpointStateToolset
An implementation of
CheckpointStateToolset that does file based duplicating with as
DuplicatingFileSystem . |
Modifier and Type | Method and Description |
---|---|
CheckpointStateToolset |
FsCheckpointStorageAccess.createTaskOwnedCheckpointStateToolset() |
Modifier and Type | Method and Description |
---|---|
CheckpointStateToolset |
MemoryBackendCheckpointStorageAccess.createTaskOwnedCheckpointStateToolset() |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.