Modifier and Type | Method and Description |
---|---|
static BufferConsumer |
EventSerializer.toBufferConsumer(AbstractEvent event) |
Modifier and Type | Method and Description |
---|---|
protected void |
RecordWriter.addBufferConsumer(BufferConsumer consumer,
int targetChannel) |
default boolean |
ResultPartitionWriter.addBufferConsumer(BufferConsumer bufferConsumer,
int subpartitionIndex)
Adds the bufferConsumer to the subpartition with the given index.
|
boolean |
ResultPartitionWriter.addBufferConsumer(BufferConsumer bufferConsumer,
int subpartitionIndex,
boolean isPriorityEvent)
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 |
---|---|
boolean |
ResultSubpartition.add(BufferConsumer bufferConsumer)
Adds the given buffer.
|
boolean |
PipelinedSubpartition.add(BufferConsumer bufferConsumer,
boolean isPriorityEvent) |
abstract boolean |
ResultSubpartition.add(BufferConsumer bufferConsumer,
boolean isPriorityEvent)
Adds the given buffer.
|
boolean |
ResultPartition.addBufferConsumer(BufferConsumer bufferConsumer,
int subpartitionIndex,
boolean isPriorityEvent) |
boolean |
PipelinedSubpartitionView.notifyPriorityEvent(BufferConsumer eventBufferConsumer) |
default boolean |
BufferAvailabilityListener.notifyPriorityEvent(BufferConsumer eventBufferConsumer)
Allows the listener to react to a priority event before it is added to the outgoing buffer
queue.
|
Modifier and Type | Method and Description |
---|---|
boolean |
LocalInputChannel.notifyPriorityEvent(BufferConsumer eventBufferConsumer) |
Modifier and Type | Method and Description |
---|---|
boolean |
ConsumableNotifyingResultPartitionWriterDecorator.addBufferConsumer(BufferConsumer bufferConsumer,
int subpartitionIndex,
boolean isPriorityEvent) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.