Package | Description |
---|---|
org.apache.flink.state.api | |
org.apache.flink.state.api.output |
Modifier and Type | Method and Description |
---|---|
StreamOperator<TaggedOperatorSubtaskState> |
SavepointWriterOperatorFactory.createOperator(long savepointTimestamp,
Path savepointPath)
Creates a
StreamOperator to be used for generating and snapshotting state. |
Modifier and Type | Method and Description |
---|---|
static <OUT,OP extends StreamOperator<OUT>> |
SnapshotUtils.snapshot(OP operator,
int index,
long timestamp,
CheckpointStorageWorkerView checkpointStorage,
Path savepointPath) |
Modifier and Type | Method and Description |
---|---|
void |
BoundedOneInputStreamTaskRunner.mapPartition(Iterable<IN> values,
Collector<TaggedOperatorSubtaskState> out) |
void |
OperatorSubtaskStateReducer.reduce(Iterable<TaggedOperatorSubtaskState> values,
Collector<OperatorState> out) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.