Package | Description |
---|---|
org.apache.flink.runtime.state | |
org.apache.flink.runtime.state.filesystem | |
org.apache.flink.runtime.state.memory |
Modifier and Type | Field and Description |
---|---|
protected CheckpointStreamFactory.CheckpointStateOutputStream |
NonClosingCheckpointOutputStream.delegate |
Modifier and Type | Method and Description |
---|---|
CheckpointStreamFactory.CheckpointStateOutputStream |
CheckpointStreamFactory.createCheckpointStateOutputStream(long checkpointID,
long timestamp)
Creates an new
CheckpointStreamFactory.CheckpointStateOutputStream . |
Constructor and Description |
---|
KeyedStateCheckpointOutputStream(CheckpointStreamFactory.CheckpointStateOutputStream delegate,
KeyGroupRange keyGroupRange) |
NonClosingCheckpointOutputStream(CheckpointStreamFactory.CheckpointStateOutputStream delegate) |
OperatorStateCheckpointOutputStream(CheckpointStreamFactory.CheckpointStateOutputStream delegate) |
Modifier and Type | Class and Description |
---|---|
static class |
FsCheckpointStreamFactory.FsCheckpointStateOutputStream
A
CheckpointStreamFactory.CheckpointStateOutputStream that writes into a file and
returns a StreamStateHandle upon closing. |
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(long checkpointID,
long timestamp) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.