alluxio.worker.grpc

Class BlockReadHandler

java.lang.Object

alluxio.worker.grpc.BlockReadHandler

All Implemented Interfaces:

io.grpc.stub.StreamObserver<ReadRequest>

@NotThreadSafe
public final class BlockReadHandler
extends Object

This handler handles block read request. Check more information in AbstractReadHandler.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	BlockReadHandler.BlockDataReader The data reader to read from a local block worker.

Field Summary

Fields

Modifier and Type	Field and Description
protected Executor	mSerializingExecutor A serializing executor for sending responses.
protected AuthenticatedUserInfo	mUserInfo

Constructor Summary

Constructors

Constructor and Description
BlockReadHandler(ExecutorService executorService, BlockWorker blockWorker, io.grpc.stub.StreamObserver<ReadResponse> responseObserver, AuthenticatedUserInfo userInfo, boolean domainSocketEnabled) Creates an instance of AbstractReadHandler.

Method Summary

Modifier and Type	Method and Description
protected alluxio.worker.grpc.AbstractReadHandler.DataReader	createDataReader(BlockReadRequestContext context, io.grpc.stub.StreamObserver<ReadResponse> response) Creates a read reader.
protected BlockReadRequestContext	createRequestContext(ReadRequest request)
void	onCompleted()
void	onError(Throwable cause)
void	onNext(ReadRequest request)
void	onReady()
boolean	tooManyPendingChunks()

Methods inherited from class java.lang.Object

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

Field Detail

mSerializingExecutor

protected Executor mSerializingExecutor

A serializing executor for sending responses.

mUserInfo

protected AuthenticatedUserInfo mUserInfo

Constructor Detail

BlockReadHandler

public BlockReadHandler(ExecutorService executorService,
                        BlockWorker blockWorker,
                        io.grpc.stub.StreamObserver<ReadResponse> responseObserver,
                        AuthenticatedUserInfo userInfo,
                        boolean domainSocketEnabled)

Creates an instance of AbstractReadHandler.

Parameters:

executorService - the executor service to run DataReaders

blockWorker - the block worker

responseObserver - the response observer of the gRPC stream

userInfo - the authenticated user info

domainSocketEnabled - whether reading block over domain socket

Method Detail

createRequestContext

protected BlockReadRequestContext createRequestContext(ReadRequest request)

Parameters:

request - the block read request

Returns:

an instance of read request based on the request read from channel

createDataReader

protected alluxio.worker.grpc.AbstractReadHandler.DataReader createDataReader(BlockReadRequestContext context,
                                                                              io.grpc.stub.StreamObserver<ReadResponse> response)

Creates a read reader.

Parameters:

context - read request context

response - channel

Returns:

the data reader for this handler

onNext

public void onNext(ReadRequest request)

Specified by:

onNext in interface io.grpc.stub.StreamObserver<ReadRequest>

tooManyPendingChunks

public boolean tooManyPendingChunks()

Returns:

true if there are too many chunks in-flight

onError

public void onError(Throwable cause)

Specified by:

onError in interface io.grpc.stub.StreamObserver<ReadRequest>

onCompleted

public void onCompleted()

Specified by:

onCompleted in interface io.grpc.stub.StreamObserver<ReadRequest>

onReady

public void onReady()