Modifier and Type | Method and Description |
---|---|
static BufferConsumer |
EventSerializer.toBufferConsumer(AbstractEvent event) |
Modifier and Type | Method and Description |
---|---|
boolean |
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 |
BufferConsumer.copyWithReaderPosition(int readerPosition)
Returns a retained copy with separate indexes and sets the reader position to the given value.
|
BufferConsumer |
BufferBuilder.createBufferConsumer()
This method always creates a
BufferConsumer starting from the current writer offset. |
Modifier and Type | Method and Description |
---|---|
abstract boolean |
ResultSubpartition.add(BufferConsumer bufferConsumer)
Adds the given buffer.
|
boolean |
ResultPartition.addBufferConsumer(BufferConsumer bufferConsumer,
int subpartitionIndex) |
Modifier and Type | Method and Description |
---|---|
boolean |
ConsumableNotifyingResultPartitionWriterDecorator.addBufferConsumer(BufferConsumer bufferConsumer,
int subpartitionIndex) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.