public interface CheckpointedResultSubpartition
Modifier and Type | Method and Description |
---|---|
void |
addRecovered(BufferConsumer bufferConsumer) |
void |
finishReadRecoveredState(boolean notifyAndBlockOnCompletion) |
ResultSubpartitionInfo |
getSubpartitionInfo() |
BufferBuilder |
requestBufferBuilderBlocking() |
ResultSubpartitionInfo getSubpartitionInfo()
BufferBuilder requestBufferBuilderBlocking() throws IOException, RuntimeException, InterruptedException
void addRecovered(BufferConsumer bufferConsumer) throws IOException
IOException
void finishReadRecoveredState(boolean notifyAndBlockOnCompletion) throws IOException
IOException
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.