M
- The type of the message to be deserialized. It has to extend MessageBody
public interface MessageDeserializer<M extends MessageBody>
message
.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) |
M deserializeMessage(org.apache.paimon.shade.netty4.io.netty.buffer.ByteBuf buf)
buf
- the buffer containing the message.static byte[] readBytes(org.apache.paimon.shade.netty4.io.netty.buffer.ByteBuf buf, int len)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.