Modifier and Type | Method and Description |
---|---|
void |
CompactCoordinator.snapshotState(StateSnapshotContext context) |
void |
CompactorOperator.snapshotState(StateSnapshotContext context) |
void |
CompactorOperatorStateHandler.snapshotState(StateSnapshotContext context) |
Modifier and Type | Method and Description |
---|---|
void |
StreamingFileWriter.snapshotState(StateSnapshotContext context) |
void |
AbstractStreamingWriter.snapshotState(StateSnapshotContext context) |
void |
PartitionCommitter.snapshotState(StateSnapshotContext context) |
Modifier and Type | Method and Description |
---|---|
void |
CompactCoordinator.snapshotState(StateSnapshotContext context) |
void |
CompactOperator.snapshotState(StateSnapshotContext context) |
Modifier and Type | Class and Description |
---|---|
class |
StateSnapshotContextSynchronousImpl
This class is a default implementation for StateSnapshotContext.
|
Modifier and Type | Method and Description |
---|---|
void |
ContinuousFileReaderOperator.snapshotState(StateSnapshotContext context) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractUdfStreamOperator.snapshotState(StateSnapshotContext context) |
void |
AbstractStreamOperator.snapshotState(StateSnapshotContext context)
Stream operators with state, which want to participate in a snapshot need to override this
hook method.
|
void |
SourceOperator.snapshotState(StateSnapshotContext context) |
void |
AbstractStreamOperatorV2.snapshotState(StateSnapshotContext context)
Stream operators with state, which want to participate in a snapshot need to override this
hook method.
|
void |
StreamOperatorStateHandler.CheckpointedStreamOperator.snapshotState(StateSnapshotContext context) |
Modifier and Type | Method and Description |
---|---|
void |
AsyncWaitOperator.snapshotState(StateSnapshotContext context) |
Modifier and Type | Method and Description |
---|---|
void |
GenericWriteAheadSink.snapshotState(StateSnapshotContext context) |
Modifier and Type | Method and Description |
---|---|
static void |
StreamingFunctionUtils.snapshotFunctionState(StateSnapshotContext context,
OperatorStateBackend backend,
Function userFunction) |
Modifier and Type | Method and Description |
---|---|
void |
StreamSortOperator.snapshotState(StateSnapshotContext context) |
Modifier and Type | Method and Description |
---|---|
void |
SlicingWindowOperator.snapshotState(StateSnapshotContext context) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.