Interface | Description |
---|---|
ChannelStateWriter |
Writes channel state during checkpoint/savepoint.
|
SequentialChannelStateReader |
Reads channel state saved during checkpoint/savepoint.
|
Class | Description |
---|---|
ChannelStatePendingResult |
The pending result of channel state for a specific checkpoint-subtask.
|
ChannelStateWriter.ChannelStateWriteResult |
Channel state write result.
|
ChannelStateWriter.NoOpChannelStateWriter |
No-op implementation of
ChannelStateWriter . |
ChannelStateWriteRequestExecutorFactory |
The factory of
ChannelStateWriteRequestExecutor . |
ChannelStateWriterImpl |
ChannelStateWriter implemented using CheckpointStateOutputStreams . |
InputChannelInfo |
Identifies
InputChannel in a given
subtask. |
ResultSubpartitionInfo |
Identifies
ResultSubpartition in a given subtask. |
SequentialChannelStateReaderImpl |
SequentialChannelStateReader implementation. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.