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(BufferProvider bufferProvider) |
abstract void |
finish() |
protected Throwable |
getFailureCause() |
protected int |
getTotalNumberOfBuffers() |
protected long |
getTotalNumberOfBytes() |
abstract boolean |
isReleased() |
protected void |
onConsumedSubpartition()
Notifies the parent partition about a consumed
ResultSubpartitionView . |
abstract void |
release() |
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 int 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(BufferProvider bufferProvider) throws IOException
IOException
public abstract boolean isReleased()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.