Package | Description |
---|---|
org.apache.flink.runtime.state | |
org.apache.flink.runtime.state.filesystem | |
org.apache.flink.runtime.state.memory |
Modifier and Type | Method and Description |
---|---|
static CheckpointedStateScope |
CheckpointedStateScope.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static CheckpointedStateScope[] |
CheckpointedStateScope.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
CheckpointStreamFactory.CheckpointStateOutputStream |
CheckpointStreamFactory.createCheckpointStateOutputStream(CheckpointedStateScope scope)
Creates an new
CheckpointStreamFactory.CheckpointStateOutputStream . |
static CheckpointStreamWithResultProvider |
CheckpointStreamWithResultProvider.createDuplicatingStream(long checkpointId,
CheckpointedStateScope checkpointedStateScope,
CheckpointStreamFactory primaryStreamFactory,
LocalRecoveryDirectoryProvider secondaryStreamDirProvider) |
static CheckpointStreamWithResultProvider |
CheckpointStreamWithResultProvider.createSimpleStream(CheckpointedStateScope checkpointedStateScope,
CheckpointStreamFactory primaryStreamFactory) |
Modifier and Type | Method and Description |
---|---|
FsCheckpointStreamFactory.FsCheckpointStateOutputStream |
FsCheckpointStreamFactory.createCheckpointStateOutputStream(CheckpointedStateScope scope) |
Modifier and Type | Method and Description |
---|---|
CheckpointStreamFactory.CheckpointStateOutputStream |
MemCheckpointStreamFactory.createCheckpointStateOutputStream(CheckpointedStateScope scope) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.