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,
String taskName,
ResultSubpartitionInfo channelInfo) |
Modifier and Type | Method and Description |
---|---|
int |
ResultSubpartition.add(BufferConsumer bufferConsumer) |
int |
PipelinedSubpartition.add(BufferConsumer bufferConsumer,
int partialRecordLength) |
abstract int |
ResultSubpartition.add(BufferConsumer bufferConsumer,
int partialRecordLength)
Adds the given buffer.
|
void |
PipelinedSubpartition.addRecovered(BufferConsumer bufferConsumer) |
void |
CheckpointedResultSubpartition.addRecovered(BufferConsumer bufferConsumer) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.