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 |
DuplicatingCheckpointOutputStream
A CheckpointStateOutputStream that wraps a primary and a secondary CheckpointStateOutputStream
and duplicates all writes into both streams.
|
Modifier and Type | Field and Description |
---|---|
protected CheckpointStreamFactory.CheckpointStateOutputStream |
NonClosingCheckpointOutputStream.delegate |
Modifier and Type | Method and Description |
---|---|
CheckpointStreamFactory.CheckpointStateOutputStream |
CheckpointStreamFactory.createCheckpointStateOutputStream(CheckpointedStateScope scope)
Creates an new
CheckpointStreamFactory.CheckpointStateOutputStream . |
CheckpointStreamFactory.CheckpointStateOutputStream |
CheckpointStorageWorkerView.createTaskOwnedStateStream()
Opens a stream to persist checkpoint state data that is owned strictly by tasks and not
attached to the life cycle of a specific checkpoint.
|
CheckpointStreamFactory.CheckpointStateOutputStream |
CheckpointStreamWithResultProvider.getCheckpointOutputStream()
Returns the encapsulated output stream.
|
CheckpointStreamFactory.CheckpointStateOutputStream |
CheckpointStreamWithResultProvider.PrimaryStreamOnly.getCheckpointOutputStream() |
Modifier and Type | Class and Description |
---|---|
class |
FileBasedStateOutputStream
A
CheckpointStreamFactory.CheckpointStateOutputStream that writes into a specified file and returns a FileStateHandle upon closing. |
static class |
FsCheckpointStreamFactory.FsCheckpointStateOutputStream
A
CheckpointStreamFactory.CheckpointStateOutputStream that writes into a file and
returns a StreamStateHandle upon closing. |
Modifier and Type | Method and Description |
---|---|
CheckpointStreamFactory.CheckpointStateOutputStream |
FsCheckpointStorageAccess.createTaskOwnedStateStream() |
Modifier and Type | Class and Description |
---|---|
static class |
MemCheckpointStreamFactory.MemoryCheckpointOutputStream
A
CheckpointStateOutputStream that writes into a byte array. |
Modifier and Type | Method and Description |
---|---|
CheckpointStreamFactory.CheckpointStateOutputStream |
MemCheckpointStreamFactory.createCheckpointStateOutputStream(CheckpointedStateScope scope) |
CheckpointStreamFactory.CheckpointStateOutputStream |
MemoryBackendCheckpointStorageAccess.createTaskOwnedStateStream() |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.