Modifier and Type | Class and Description |
---|---|
class |
ChannelStateReaderImpl
ChannelStateReader implementation. |
Modifier and Type | Field and Description |
---|---|
static ChannelStateReader |
ChannelStateReader.NO_OP |
Modifier and Type | Method and Description |
---|---|
void |
ResultPartitionWriter.readRecoveredState(ChannelStateReader stateReader)
Reads the previous output states with the given reader for unaligned checkpoint.
|
Modifier and Type | Method and Description |
---|---|
void |
ResultPartition.readRecoveredState(ChannelStateReader stateReader) |
void |
PipelinedSubpartition.readRecoveredState(ChannelStateReader stateReader) |
void |
ResultSubpartition.readRecoveredState(ChannelStateReader stateReader) |
Modifier and Type | Method and Description |
---|---|
protected void |
RecoveredInputChannel.readRecoveredState(ChannelStateReader reader) |
CompletableFuture<?> |
SingleInputGate.readRecoveredState(ExecutorService executor,
ChannelStateReader reader) |
CompletableFuture<?> |
UnionInputGate.readRecoveredState(ExecutorService executor,
ChannelStateReader reader) |
abstract CompletableFuture<?> |
InputGate.readRecoveredState(ExecutorService executor,
ChannelStateReader reader)
Reads the previous unaligned checkpoint states before requesting partition data.
|
Modifier and Type | Method and Description |
---|---|
ChannelStateReader |
TaskStateManagerImpl.getChannelStateReader() |
ChannelStateReader |
TaskStateManager.getChannelStateReader() |
Constructor and Description |
---|
TaskStateManagerImpl(JobID jobId,
ExecutionAttemptID executionAttemptID,
TaskLocalStateStore localStateStore,
JobManagerTaskRestore jobManagerTaskRestore,
CheckpointResponder checkpointResponder,
ChannelStateReader channelStateReader) |
Modifier and Type | Method and Description |
---|---|
void |
ConsumableNotifyingResultPartitionWriterDecorator.readRecoveredState(ChannelStateReader stateReader) |
CompletableFuture<?> |
InputGateWithMetrics.readRecoveredState(ExecutorService executor,
ChannelStateReader reader) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.