alluxio.grpc

Class ReadResponseMarshaller

java.lang.Object

alluxio.grpc.DataMessageMarshaller<ReadResponse>

alluxio.grpc.ReadResponseMarshaller

All Implemented Interfaces:

BufferRepository<ReadResponse,DataBuffer>, io.grpc.MethodDescriptor.Marshaller<ReadResponse>, Closeable, AutoCloseable

@NotThreadSafe
public class ReadResponseMarshaller
extends DataMessageMarshaller<ReadResponse>

Marshaller for ReadResponse.

Constructor Summary

Constructors

Constructor and Description
ReadResponseMarshaller() Creates a ReadResponseMarshaller.

Method Summary

Modifier and Type	Method and Description
ReadResponse	combineData(DataMessage<ReadResponse,DataBuffer> message) Combines the data buffer into the message.
protected ReadResponse	deserialize(io.grpc.internal.ReadableBuffer buffer) Deserialize data buffer to the message.
protected io.netty.buffer.ByteBuf[]	serialize(ReadResponse message) Serialize the message to buffers.

Methods inherited from class alluxio.grpc.DataMessageMarshaller

close, offerBuffer, parse, pollBuffer, stream

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ReadResponseMarshaller

public ReadResponseMarshaller()

Creates a ReadResponseMarshaller.

Method Detail

serialize

protected io.netty.buffer.ByteBuf[] serialize(ReadResponse message)
                                       throws IOException

Description copied from class: DataMessageMarshaller

Serialize the message to buffers.

Specified by:

serialize in class DataMessageMarshaller<ReadResponse>

Parameters:

message - the message to be serialized

Returns:

an array of ByteBufs containing the serialized message

Throws:

IOException - if the marshaller fails to serialize the message

deserialize

protected ReadResponse deserialize(io.grpc.internal.ReadableBuffer buffer)
                            throws IOException

Description copied from class: DataMessageMarshaller

Deserialize data buffer to the message.

Specified by:

deserialize in class DataMessageMarshaller<ReadResponse>

Parameters:

buffer - the buffer that contains the message data

Returns:

the deserialized message

Throws:

IOException - if the marshaller fails to deserialize the data

combineData

public ReadResponse combineData(@Nullable
                                DataMessage<ReadResponse,DataBuffer> message)

Description copied from class: DataMessageMarshaller

Combines the data buffer into the message.

Specified by:

combineData in class DataMessageMarshaller<ReadResponse>

Parameters:

message - the message to be combined

Returns:

the message with the combined buffer