Package | Description |
---|---|
org.apache.flink.runtime.io.network.buffer | |
org.apache.flink.runtime.io.network.partition | |
org.apache.flink.runtime.io.network.partition.consumer |
Modifier and Type | Method and Description |
---|---|
Buffer.DataType |
FileRegionBuffer.getDataType() |
Buffer.DataType |
ReadOnlySlicedNetworkBuffer.getDataType() |
Buffer.DataType |
BufferConsumer.getDataType() |
Buffer.DataType |
NetworkBuffer.getDataType() |
Buffer.DataType |
Buffer.getDataType()
Gets the type of data this buffer represents.
|
static Buffer.DataType |
Buffer.DataType.getDataType(AbstractEvent event,
boolean hasPriority) |
static Buffer.DataType |
Buffer.DataType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static Buffer.DataType[] |
Buffer.DataType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
void |
FileRegionBuffer.setDataType(Buffer.DataType dataType) |
void |
ReadOnlySlicedNetworkBuffer.setDataType(Buffer.DataType dataType) |
void |
NetworkBuffer.setDataType(Buffer.DataType dataType) |
void |
Buffer.setDataType(Buffer.DataType dataType)
Sets the type of data this buffer represents.
|
Constructor and Description |
---|
FileRegionBuffer(FileChannel fileChannel,
long fileChannelPosition,
int bufferSize,
Buffer.DataType dataType,
boolean isCompressed) |
NetworkBuffer(MemorySegment memorySegment,
BufferRecycler recycler,
Buffer.DataType dataType)
Creates a new buffer instance backed by the given memorySegment with 0 for
the readerIndex and writerIndex.
|
NetworkBuffer(MemorySegment memorySegment,
BufferRecycler recycler,
Buffer.DataType dataType,
boolean isCompressed,
int size)
Creates a new buffer instance backed by the given memorySegment with 0 for
the readerIndex and size as writerIndex.
|
NetworkBuffer(MemorySegment memorySegment,
BufferRecycler recycler,
Buffer.DataType dataType,
int size)
Creates a new buffer instance backed by the given memorySegment with 0 for
the readerIndex and size as writerIndex.
|
Modifier and Type | Method and Description |
---|---|
Buffer.DataType |
ResultSubpartition.BufferAndBacklog.getNextDataType() |
Modifier and Type | Method and Description |
---|---|
boolean |
HashBasedDataBuffer.append(ByteBuffer source,
int targetChannel,
Buffer.DataType dataType)
Partial data of the target record can be written if this
HashBasedDataBuffer is full. |
boolean |
DataBuffer.append(ByteBuffer source,
int targetChannel,
Buffer.DataType dataType)
Appends data of the specified channel to this
DataBuffer and returns true if this
DataBuffer is full. |
boolean |
SortBasedDataBuffer.append(ByteBuffer source,
int targetChannel,
Buffer.DataType dataType)
No partial record will be written to this
SortBasedDataBuffer , which means that
either all data of target record will be written or nothing will be written. |
static ResultSubpartition.BufferAndBacklog |
ResultSubpartition.BufferAndBacklog.fromBufferAndLookahead(Buffer current,
Buffer.DataType nextDataType,
int backlog,
int sequenceNumber) |
Constructor and Description |
---|
BufferAndBacklog(Buffer buffer,
int buffersInBacklog,
Buffer.DataType nextDataType,
int sequenceNumber) |
Constructor and Description |
---|
BufferAndAvailability(Buffer buffer,
Buffer.DataType nextDataType,
int buffersInBacklog,
int sequenceNumber) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.