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 |
CheckpointStorage.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 |
FsCheckpointStorage.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 |
MemoryBackendCheckpointStorage.createTaskOwnedStateStream() |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.