Modifier and Type | Method and Description |
---|---|
AbstractStateBackend.CheckpointStateOutputStream |
DbStateBackend.createCheckpointStateOutputStream(long checkpointID,
long timestamp) |
AbstractStateBackend.CheckpointStateOutputStream |
RocksDBStateBackend.createCheckpointStateOutputStream(long checkpointID,
long timestamp) |
Modifier and Type | Method and Description |
---|---|
abstract AbstractStateBackend.CheckpointStateOutputStream |
AbstractStateBackend.createCheckpointStateOutputStream(long checkpointID,
long timestamp)
Creates an output stream that writes into the state of the given checkpoint.
|
Constructor and Description |
---|
CheckpointStateOutputView(AbstractStateBackend.CheckpointStateOutputStream out) |
Modifier and Type | Class and Description |
---|---|
static class |
FsStateBackend.FsCheckpointStateOutputStream
A CheckpointStateOutputStream that writes into a file and returns the path to that file upon
closing.
|
Modifier and Type | Class and Description |
---|---|
static class |
MemoryStateBackend.MemoryCheckpointOutputStream
A CheckpointStateOutputStream that writes into a byte array.
|
Modifier and Type | Method and Description |
---|---|
AbstractStateBackend.CheckpointStateOutputStream |
MemoryStateBackend.createCheckpointStateOutputStream(long checkpointID,
long timestamp) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.