alluxio.worker.grpc

Class FileReadHandler

java.lang.Object

alluxio.worker.grpc.FileReadHandler

All Implemented Interfaces:

io.grpc.stub.StreamObserver<ReadRequest>

public class FileReadHandler
extends Object
implements io.grpc.stub.StreamObserver<ReadRequest>

Handles file read request.

Method Summary

Modifier and Type	Method and Description
protected BlockReadRequestContext	createRequestContext(ReadRequest request)
void	onCompleted()
void	onError(Throwable cause)
void	onNext(ReadRequest request)
void	onReady() Ready to restart data reader.
boolean	tooManyPendingChunks()

Methods inherited from class java.lang.Object

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

Method Detail

onNext

public void onNext(ReadRequest request)

Specified by:

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

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>

tooManyPendingChunks

public boolean tooManyPendingChunks()

Returns:

true if there are too many chunks in-flight

onReady

public void onReady()

Ready to restart data reader.

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