Interface MessageDeserializer<M extends MessageBody>

    • Method Detail

      • deserializeMessage

        M deserializeMessage​(org.apache.flink.shaded.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.