org.apache.flink.runtime.io.network.partition

Interface CheckpointedResultPartition

All Known Implementing Classes:

PipelinedResultPartition

public interface CheckpointedResultPartition

Interface for partitions that are checkpointed, meaning they store data as part of unaligned checkpoints.

Method Summary

Modifier and Type	Method and Description
void	finishReadRecoveredState(boolean notifyAndBlockOnCompletion)
CheckpointedResultSubpartition	getCheckpointedSubpartition(int subpartitionIndex) Gets the checkpointed subpartition with the given subpartitionIndex.

Method Detail

getCheckpointedSubpartition

CheckpointedResultSubpartition getCheckpointedSubpartition(int subpartitionIndex)

Gets the checkpointed subpartition with the given subpartitionIndex.

finishReadRecoveredState

void finishReadRecoveredState(boolean notifyAndBlockOnCompletion)
                       throws IOException

Throws:

IOException