Package | Description |
---|---|
alluxio.client.block.stream | |
alluxio.network.protocol | |
alluxio.network.protocol.databuffer | |
alluxio.worker.netty |
Modifier and Type | Method and Description |
---|---|
DataBuffer |
LocalFilePacketReader.readPacket() |
DataBuffer |
NettyPacketReader.readPacket() |
DataBuffer |
PacketReader.readPacket()
Reads a packet.
|
Modifier and Type | Method and Description |
---|---|
DataBuffer |
RPCProtoMessage.getPayloadDataBuffer() |
DataBuffer |
RPCMessage.getPayloadDataBuffer()
Returns the data buffer of the payload.
|
Modifier and Type | Method and Description |
---|---|
static RPCProtoMessage |
RPCProtoMessage.createOkResponse(DataBuffer data)
Creates an OK response with data.
|
static RPCProtoMessage |
RPCProtoMessage.createResponse(Status status,
String message,
DataBuffer data)
Creates a response for a given status, message, and data buffer.
|
Constructor and Description |
---|
RPCProtoMessage(byte[] serialized,
ProtoMessage prototype,
DataBuffer data)
Creates an instance of
RPCProtoMessage from a serialized proto message. |
RPCProtoMessage(ProtoMessage message,
DataBuffer data)
Creates an instance of
RPCProtoMessage . |
Modifier and Type | Class and Description |
---|---|
class |
DataByteArrayChannel
A DataBuffer backed by a byte[].
|
class |
DataByteBuffer
A DataBuffer with the underlying data being a
ByteBuffer . |
class |
DataFileChannel
A DataBuffer with the underlying data being a
FileChannel . |
class |
DataNettyBuffer
A DataBuffer with the underlying data being a
ByteBuf . |
class |
DataNettyBufferV2
A DataBuffer with the underlying data being a
ByteBuf . |
Modifier and Type | Method and Description |
---|---|
protected DataBuffer |
BlockReadHandler.BlockPacketReader.getDataBuffer(BlockReadRequestContext context,
io.netty.channel.Channel channel,
long offset,
int len) |
Copyright © 2023. All Rights Reserved.