org.apache.paimon.service.network.messages

Interface MessageDeserializer<M extends MessageBody>

Type Parameters:

M - The type of the message to be deserialized. It has to extend MessageBody

All Known Implementing Classes:

KvRequest.KvRequestDeserializer, KvResponse.KvResponseDeserializer

public interface MessageDeserializer<M extends MessageBody>

A utility used to deserialize a message.

Method Summary

Modifier and Type	Method and Description
M	deserializeMessage(org.apache.paimon.shade.netty4.io.netty.buffer.ByteBuf buf) Deserializes a message contained in a byte buffer.
static byte[]	readBytes(org.apache.paimon.shade.netty4.io.netty.buffer.ByteBuf buf, int len)

Method Detail

deserializeMessage

M deserializeMessage(org.apache.paimon.shade.netty4.io.netty.buffer.ByteBuf buf)

Deserializes a message contained in a byte buffer.

Parameters:

buf - the buffer containing the message.

Returns:

The deserialized message.

readBytes

static byte[] readBytes(org.apache.paimon.shade.netty4.io.netty.buffer.ByteBuf buf,
                        int len)