Class and Description |
---|
ChannelStateWriter
Writes channel state during checkpoint/savepoint.
|
ChannelStateWriter.ChannelStateWriteResult
Channel state write result.
|
InputChannelInfo
Identifies
InputChannel in a given
subtask. |
ResultSubpartitionInfo
Identifies
ResultSubpartition in a given subtask. |
SequentialChannelStateReader
Reads channel state saved during checkpoint/savepoint.
|
Class and Description |
---|
InputChannelInfo
Identifies
InputChannel in a given
subtask. |
ResultSubpartitionInfo
Identifies
ResultSubpartition in a given subtask. |
Class and Description |
---|
ChannelStateWriter
Writes channel state during checkpoint/savepoint.
|
ResultSubpartitionInfo
Identifies
ResultSubpartition in a given subtask. |
Class and Description |
---|
ChannelStateWriter
Writes channel state during checkpoint/savepoint.
|
InputChannelInfo
Identifies
InputChannel in a given
subtask. |
Class and Description |
---|
InputChannelInfo
Identifies
InputChannel in a given
subtask. |
ResultSubpartitionInfo
Identifies
ResultSubpartition in a given subtask. |
SequentialChannelStateReader
Reads channel state saved during checkpoint/savepoint.
|
SequentialChannelStateReaderImpl
SequentialChannelStateReader implementation. |
Class and Description |
---|
ChannelStateWriter
Writes channel state during checkpoint/savepoint.
|
InputChannelInfo
Identifies
InputChannel in a given
subtask. |
Class and Description |
---|
ChannelStateWriter
Writes channel state during checkpoint/savepoint.
|
Class and Description |
---|
ChannelStateWriter
Writes channel state during checkpoint/savepoint.
|
InputChannelInfo
Identifies
InputChannel in a given
subtask. |
Class and Description |
---|
InputChannelInfo
Identifies
InputChannel in a given
subtask. |
Class and Description |
---|
ChannelStateWriter
Writes channel state during checkpoint/savepoint.
|
InputChannelInfo
Identifies
InputChannel in a given
subtask. |
Class and Description |
---|
ChannelStateWriter
Writes channel state during checkpoint/savepoint.
|
ChannelStateWriter.ChannelStateWriteResult
Channel state write result.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.