Package | Description |
---|---|
org.apache.flink.runtime.io.network.buffer |
Modifier and Type | Method and Description |
---|---|
Buffer.DataType |
Buffer.getDataType()
Gets the type of data this buffer represents.
|
Buffer.DataType |
ReadOnlySlicedNetworkBuffer.getDataType() |
Buffer.DataType |
NetworkBuffer.getDataType() |
static Buffer.DataType |
Buffer.DataType.getDataType(AbstractEvent event) |
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 |
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. |
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.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.