public class ReleaseOnConsumptionResultPartition extends ResultPartition
AvailabilityProvider.AvailabilityHelper
bufferCompressor, LOG, numTargetKeyGroups, partitionId, partitionManager, partitionType, subpartitions
AVAILABLE
Modifier and Type | Method and Description |
---|---|
void |
close() |
ResultSubpartitionView |
createSubpartitionView(int index,
BufferAvailabilityListener availabilityListener)
Returns the requested subpartition.
|
String |
toString() |
addBufferConsumer, fail, finish, flush, flushAll, getAllPartitions, getAvailableFuture, getBufferBuilder, getBufferPool, getFailureCause, getNumberOfQueuedBuffers, getNumberOfSubpartitions, getNumTargetKeyGroups, getOwningTaskName, getPartitionId, getPartitionIndex, getPartitionType, getSubpartition, isReleased, readRecoveredState, release, release, releaseMemory, setup, tryGetBufferBuilder
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addBufferConsumer
isApproximatelyAvailable, isAvailable
public ResultSubpartitionView createSubpartitionView(int index, BufferAvailabilityListener availabilityListener) throws IOException
ResultPartition
createSubpartitionView
in class ResultPartition
IOException
public String toString()
toString
in class ResultPartition
public void close()
close
in interface AutoCloseable
close
in class ResultPartition
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.