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 |
PartitionSortedBuffer.append(ByteBuffer source,
int targetChannel,
Buffer.DataType dataType) |
boolean |
SortBuffer.append(ByteBuffer source,
int targetChannel,
Buffer.DataType dataType)
Appends data of the specified channel to this
SortBuffer and returns true if all
bytes of the source buffer is copied to this SortBuffer successfully, otherwise if
returns false, nothing will be copied. |
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.