Modifier and Type | Method and Description |
---|---|
static BufferConsumer |
EventSerializer.toBufferConsumer(AbstractEvent event) |
Modifier and Type | Method and Description |
---|---|
void |
ResultPartitionWriter.addBufferConsumer(BufferConsumer bufferConsumer,
int subpartitionIndex)
Adds the bufferConsumer to the subpartition with the given index.
|
Modifier and Type | Method and Description |
---|---|
BufferConsumer |
BufferConsumer.copy()
Returns a retained copy with separate indexes.
|
BufferConsumer |
BufferBuilder.createBufferConsumer() |
Modifier and Type | Field and Description |
---|---|
protected ArrayDeque<BufferConsumer> |
ResultSubpartition.buffers
All buffers of this subpartition.
|
Modifier and Type | Method and Description |
---|---|
abstract boolean |
ResultSubpartition.add(BufferConsumer bufferConsumer)
Adds the given buffer.
|
void |
ResultPartition.addBufferConsumer(BufferConsumer bufferConsumer,
int subpartitionIndex) |
protected void |
ResultSubpartition.increaseBuffersInBacklog(BufferConsumer buffer)
Increases the number of non-event buffers by one after adding a non-event
buffer into this subpartition.
|
protected void |
ResultSubpartition.updateStatistics(BufferConsumer buffer) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.