public class ReleaseOnConsumptionResultPartition extends ResultPartition
LOG, numTargetKeyGroups, partitionId, partitionManager, partitionType, subpartitions
Modifier and Type | Method and Description |
---|---|
ResultSubpartitionView |
createSubpartitionView(int index,
BufferAvailabilityListener availabilityListener)
Returns the requested subpartition.
|
String |
toString() |
addBufferConsumer, close, fail, finish, flush, flushAll, getAllPartitions, getBufferBuilder, getBufferPool, getFailureCause, getNumberOfQueuedBuffers, getNumberOfSubpartitions, getNumTargetKeyGroups, getOwningTaskName, getPartitionId, getPartitionType, isReleased, release, release, releaseMemory, setup
public ResultSubpartitionView createSubpartitionView(int index, BufferAvailabilityListener availabilityListener) throws IOException
ResultPartition
createSubpartitionView
in class ResultPartition
IOException
public String toString()
toString
in class ResultPartition
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.