public abstract class ResultSubpartition extends Object
ResultPartition
instance.Modifier and Type | Field and Description |
---|---|
protected int |
index
The index of the subpartition at the parent partition.
|
protected ResultPartition |
parent
The parent partition this subpartition belongs to.
|
Constructor and Description |
---|
ResultSubpartition(int index,
ResultPartition parent) |
Modifier and Type | Method and Description |
---|---|
abstract boolean |
add(Buffer buffer) |
abstract ResultSubpartitionView |
createReadView(BufferAvailabilityListener availabilityListener) |
abstract void |
finish() |
protected Throwable |
getFailureCause() |
protected long |
getTotalNumberOfBuffers() |
protected long |
getTotalNumberOfBytes() |
abstract boolean |
isReleased() |
protected void |
onConsumedSubpartition()
Notifies the parent partition about a consumed
ResultSubpartitionView . |
abstract void |
release() |
abstract int |
unsynchronizedGetNumberOfQueuedBuffers()
Makes a best effort to get the current size of the queue.
|
protected void |
updateStatistics(Buffer buffer) |
protected final int index
protected final ResultPartition parent
public ResultSubpartition(int index, ResultPartition parent)
protected void updateStatistics(Buffer buffer)
protected long getTotalNumberOfBuffers()
protected long getTotalNumberOfBytes()
protected void onConsumedSubpartition()
ResultSubpartitionView
.protected Throwable getFailureCause()
public abstract boolean add(Buffer buffer) throws IOException
IOException
public abstract void finish() throws IOException
IOException
public abstract void release() throws IOException
IOException
public abstract ResultSubpartitionView createReadView(BufferAvailabilityListener availabilityListener) throws IOException
IOException
public abstract boolean isReleased()
public abstract int unsynchronizedGetNumberOfQueuedBuffers()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.