Modifier and Type | Method and Description |
---|---|
Buffer.DataType |
NetworkBuffer.getDataType() |
Buffer.DataType |
ReadOnlySlicedNetworkBuffer.getDataType() |
Buffer.DataType |
CompositeBuffer.getDataType() |
Buffer.DataType |
FileRegionBuffer.getDataType() |
Buffer.DataType |
Buffer.getDataType()
Gets the type of data this buffer represents.
|
Buffer.DataType |
BufferConsumer.getDataType() |
Buffer.DataType |
BufferHeader.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 |
NetworkBuffer.setDataType(Buffer.DataType dataType) |
void |
ReadOnlySlicedNetworkBuffer.setDataType(Buffer.DataType dataType) |
void |
CompositeBuffer.setDataType(Buffer.DataType dataType) |
void |
FileRegionBuffer.setDataType(Buffer.DataType dataType) |
void |
Buffer.setDataType(Buffer.DataType dataType)
Sets the type of data this buffer represents.
|
Constructor and Description |
---|
BufferHeader(boolean isCompressed,
int length,
Buffer.DataType dataType) |
CompositeBuffer(Buffer.DataType dataType,
int length,
boolean isCompressed) |
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 |
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 |
HashBasedDataBuffer.append(ByteBuffer source,
int targetChannel,
Buffer.DataType dataType)
Partial data of the target record can be written if this
HashBasedDataBuffer 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) |
Modifier and Type | Method and Description |
---|---|
Buffer.DataType |
HsSubpartitionFileReaderImpl.BufferIndexOrError.getDataType() |
Buffer.DataType |
HsDataView.peekNextToConsumeDataType(int nextBufferToConsume)
Get dataType of next buffer to consume.
|
Buffer.DataType |
HsSubpartitionMemoryDataManager.peekNextToConsumeDataType(int nextToConsumeIndex)
Check whether the head of
HsSubpartitionMemoryDataManager.unConsumedBuffers is the buffer to be consumed next time. |
Buffer.DataType |
HsSubpartitionFileReaderImpl.peekNextToConsumeDataType(int nextBufferToConsume) |
Modifier and Type | Method and Description |
---|---|
void |
HsSubpartitionMemoryDataManager.append(ByteBuffer record,
Buffer.DataType dataType)
Append record to
HsSubpartitionMemoryDataManager . |
void |
HsMemoryDataManager.append(ByteBuffer record,
int targetChannel,
Buffer.DataType dataType)
Append record to
HsMemoryDataManager , It will be managed by HsSubpartitionMemoryDataManager witch it belongs to. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.