Uses of Class
alluxio.grpc.ReadRequest

Packages that use ReadRequest

Package	Description
alluxio.client.block.stream
alluxio.grpc
alluxio.wire
alluxio.worker.grpc

Uses of ReadRequest in alluxio.client.block.stream

Methods in alluxio.client.block.stream that return types with arguments of type ReadRequest

Modifier and Type	Method and Description
io.grpc.stub.StreamObserver<ReadRequest>	DefaultBlockWorkerClient.readBlock(io.grpc.stub.StreamObserver<ReadResponse> responseObserver)
io.grpc.stub.StreamObserver<ReadRequest>	BlockWorkerClient.readBlock(io.grpc.stub.StreamObserver<ReadResponse> responseObserver) Reads a block from the worker.

Methods in alluxio.client.block.stream with parameters of type ReadRequest

Modifier and Type	Method and Description
static BufferCachingGrpcDataReader	BufferCachingGrpcDataReader.create(FileSystemContext context, WorkerNetAddress address, ReadRequest readRequest) Creates an instance of BufferCachingGrpcDataReader for block reads.
com.google.common.util.concurrent.ListenableFuture<Object>	DefaultBlockWorkerClient.readBlockNoDataBack(ReadRequest request)
com.google.common.util.concurrent.ListenableFuture<Object>	BlockWorkerClient.readBlockNoDataBack(ReadRequest request) Reads a block with getting actual data.

Constructors in alluxio.client.block.stream with parameters of type ReadRequest

Constructor and Description
BufferCachingGrpcDataReader(WorkerNetAddress address, CloseableResource<BlockWorkerClient> client, long dataTimeoutMs, ReadRequest readRequest, GrpcBlockingStream<ReadRequest,ReadResponse> stream) Creates an instance of BufferCachingGrpcDataReader.
SharedGrpcDataReader(ReadRequest readRequest, BufferCachingGrpcDataReader reader) Creates an instance of SharedGrpcDataReader.

Constructor parameters in alluxio.client.block.stream with type arguments of type ReadRequest

Constructor and Description
BufferCachingGrpcDataReader(WorkerNetAddress address, CloseableResource<BlockWorkerClient> client, long dataTimeoutMs, ReadRequest readRequest, GrpcBlockingStream<ReadRequest,ReadResponse> stream) Creates an instance of BufferCachingGrpcDataReader.

Uses of ReadRequest in alluxio.grpc

Fields in alluxio.grpc with type parameters of type ReadRequest

Modifier and Type	Field and Description
static com.google.protobuf.Parser<ReadRequest>	ReadRequest.PARSER Deprecated.

Methods in alluxio.grpc that return ReadRequest

Modifier and Type	Method and Description
ReadRequest	ReadRequest.Builder.build()
ReadRequest	ReadRequest.Builder.buildPartial()
static ReadRequest	ReadRequest.getDefaultInstance()
ReadRequest	ReadRequest.getDefaultInstanceForType()
ReadRequest	ReadRequest.Builder.getDefaultInstanceForType()
static ReadRequest	ReadRequest.parseDelimitedFrom(InputStream input)
static ReadRequest	ReadRequest.parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ReadRequest	ReadRequest.parseFrom(byte[] data)
static ReadRequest	ReadRequest.parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ReadRequest	ReadRequest.parseFrom(ByteBuffer data)
static ReadRequest	ReadRequest.parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ReadRequest	ReadRequest.parseFrom(com.google.protobuf.ByteString data)
static ReadRequest	ReadRequest.parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ReadRequest	ReadRequest.parseFrom(com.google.protobuf.CodedInputStream input)
static ReadRequest	ReadRequest.parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ReadRequest	ReadRequest.parseFrom(InputStream input)
static ReadRequest	ReadRequest.parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)

Methods in alluxio.grpc that return types with arguments of type ReadRequest

Modifier and Type	Method and Description
com.google.protobuf.Parser<ReadRequest>	ReadRequest.getParserForType()
static io.grpc.MethodDescriptor<ReadRequest,ReadResponse>	BlockWorkerGrpc.getReadBlockMethod()
static com.google.protobuf.Parser<ReadRequest>	ReadRequest.parser()
default io.grpc.stub.StreamObserver<ReadRequest>	BlockWorkerGrpc.AsyncService.readBlock(io.grpc.stub.StreamObserver<ReadResponse> responseObserver)
io.grpc.stub.StreamObserver<ReadRequest>	BlockWorkerGrpc.BlockWorkerStub.readBlock(io.grpc.stub.StreamObserver<ReadResponse> responseObserver)

Methods in alluxio.grpc with parameters of type ReadRequest

Modifier and Type	Method and Description
ReadRequest.Builder	ReadRequest.Builder.mergeFrom(ReadRequest other)
static ReadRequest.Builder	ReadRequest.newBuilder(ReadRequest prototype)

Uses of ReadRequest in alluxio.wire

Methods in alluxio.wire with parameters of type ReadRequest

Modifier and Type	Method and Description
static BlockReadRequest	BlockReadRequest.from(ReadRequest request) Creates an instance of BlockReadRequest.

Uses of ReadRequest in alluxio.worker.grpc

Methods in alluxio.worker.grpc that return types with arguments of type ReadRequest

Modifier and Type	Method and Description
io.grpc.stub.StreamObserver<ReadRequest>	DoraWorkerClientServiceHandler.readBlock(io.grpc.stub.StreamObserver<ReadResponse> responseObserver)

Methods in alluxio.worker.grpc with parameters of type ReadRequest

Modifier and Type	Method and Description
protected BlockReadRequestContext	FileReadHandler.createRequestContext(ReadRequest request)
void	FileReadHandler.onNext(ReadRequest request)

Constructors in alluxio.worker.grpc with parameters of type ReadRequest

Constructor and Description
BlockReadRequestContext(ReadRequest request)