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