alluxio.worker.grpc

Class BlockReadHandler.BlockDataReader

java.lang.Object

alluxio.worker.grpc.BlockReadHandler.BlockDataReader

All Implemented Interfaces:

Runnable

Enclosing class:

BlockReadHandler

@NotThreadSafe
public final class BlockReadHandler.BlockDataReader
extends Object

The data reader to read from a local block worker.

Method Summary

Modifier and Type	Method and Description
protected void	completeRequest(BlockReadRequestContext context) Completes the read request.
protected DataBuffer	getDataBuffer(BlockReadRequestContext context, io.grpc.stub.StreamObserver<ReadResponse> response, long offset, int len) Returns the appropriate DataBuffer representing the data to send, depending on the configurable transfer type.

Methods inherited from class java.lang.Object

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

Method Detail

completeRequest

protected void completeRequest(BlockReadRequestContext context)
                        throws Exception

Completes the read request. When the request is closed, we should clean up any temporary state it may have accumulated.

Parameters:

context - context of the request to complete

Throws:

Exception

getDataBuffer

protected DataBuffer getDataBuffer(BlockReadRequestContext context,
                                   io.grpc.stub.StreamObserver<ReadResponse> response,
                                   long offset,
                                   int len)
                            throws Exception

Returns the appropriate DataBuffer representing the data to send, depending on the configurable transfer type.

Parameters:

context - context of the request to complete

response - the gRPC response observer

len - The length, in bytes, of the data to read from the block

Returns:

a DataBuffer representing the data

Throws:

Exception