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 |
Buffer.getDataType()
Gets the type of data this buffer represents.
|
Buffer.DataType |
BufferConsumer.getDataType() |
Buffer.DataType |
ReadOnlySlicedNetworkBuffer.getDataType() |
Buffer.DataType |
FileRegionBuffer.getDataType() |
Buffer.DataType |
NetworkBuffer.getDataType() |
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 |
Buffer.setDataType(Buffer.DataType dataType)
Sets the type of data this buffer represents.
|
void |
ReadOnlySlicedNetworkBuffer.setDataType(Buffer.DataType dataType) |
void |
FileRegionBuffer.setDataType(Buffer.DataType dataType) |
void |
NetworkBuffer.setDataType(Buffer.DataType dataType) |
Constructor and Description |
---|
BufferConsumer(MemorySegment memorySegment,
BufferRecycler recycler,
Buffer.DataType dataType)
Constructs
BufferConsumer instance with static content. |
BufferConsumer(MemorySegment memorySegment,
BufferRecycler recycler,
int size,
Buffer.DataType dataType)
Constructs
BufferConsumer instance with static content of a certain size. |
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 |
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. |
boolean |
PartitionSortedBuffer.append(ByteBuffer source,
int targetChannel,
Buffer.DataType dataType) |
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–2021 The Apache Software Foundation. All rights reserved.