Modifier and Type | Method and Description |
---|---|
static BufferConsumer |
EventSerializer.toBufferConsumer(AbstractEvent event,
boolean hasPriority) |
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. |
BufferConsumer |
BufferBuilder.createBufferConsumerFromBeginning()
This method always creates a
BufferConsumer starting from position 0 of MemorySegment . |
BufferConsumer |
BufferConsumerWithPartialRecordLength.getBufferConsumer() |
Constructor and Description |
---|
BufferConsumerWithPartialRecordLength(BufferConsumer bufferConsumer,
int partialRecordLength) |
Modifier and Type | Method and Description |
---|---|
static void |
NetworkActionsLogger.traceRecover(String action,
BufferConsumer bufferConsumer,
ResultSubpartitionInfo channelInfo) |
Modifier and Type | Method and Description |
---|---|
boolean |
ResultSubpartition.add(BufferConsumer bufferConsumer) |
boolean |
CheckpointedResultSubpartition.add(BufferConsumer bufferConsumer,
int partialRecordLength) |
boolean |
PipelinedSubpartition.add(BufferConsumer bufferConsumer,
int partialRecordLength) |
abstract boolean |
ResultSubpartition.add(BufferConsumer bufferConsumer,
int partialRecordLength)
Adds the given buffer.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.