Uses of Class
alluxio.grpc.ReadResponse

Packages that use ReadResponse

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

Uses of ReadResponse in alluxio.client.block.stream

Method parameters in alluxio.client.block.stream with type arguments of type ReadResponse

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.

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

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

Uses of ReadResponse in alluxio.grpc

Fields in alluxio.grpc with type parameters of type ReadResponse

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

Methods in alluxio.grpc that return ReadResponse

Modifier and Type	Method and Description
ReadResponse	ReadResponse.Builder.build()
ReadResponse	ReadResponse.Builder.buildPartial()
ReadResponse	ReadResponseMarshaller.combineData(DataMessage<ReadResponse,DataBuffer> message)
protected ReadResponse	ReadResponseMarshaller.deserialize(io.grpc.internal.ReadableBuffer buffer)
static ReadResponse	ReadResponse.getDefaultInstance()
ReadResponse	ReadResponse.getDefaultInstanceForType()
ReadResponse	ReadResponse.Builder.getDefaultInstanceForType()
static ReadResponse	ReadResponse.parseDelimitedFrom(InputStream input)
static ReadResponse	ReadResponse.parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ReadResponse	ReadResponse.parseFrom(byte[] data)
static ReadResponse	ReadResponse.parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ReadResponse	ReadResponse.parseFrom(ByteBuffer data)
static ReadResponse	ReadResponse.parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ReadResponse	ReadResponse.parseFrom(com.google.protobuf.ByteString data)
static ReadResponse	ReadResponse.parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ReadResponse	ReadResponse.parseFrom(com.google.protobuf.CodedInputStream input)
static ReadResponse	ReadResponse.parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ReadResponse	ReadResponse.parseFrom(InputStream input)
static ReadResponse	ReadResponse.parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)

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

Modifier and Type	Method and Description
com.google.protobuf.Parser<ReadResponse>	ReadResponse.getParserForType()
static io.grpc.MethodDescriptor<ReadRequest,ReadResponse>	BlockWorkerGrpc.getReadBlockMethod()
static com.google.protobuf.Parser<ReadResponse>	ReadResponse.parser()

Methods in alluxio.grpc with parameters of type ReadResponse

Modifier and Type	Method and Description
ReadResponse.Builder	ReadResponse.Builder.mergeFrom(ReadResponse other)
static ReadResponse.Builder	ReadResponse.newBuilder(ReadResponse prototype)
protected io.netty.buffer.ByteBuf[]	ReadResponseMarshaller.serialize(ReadResponse message)

Method parameters in alluxio.grpc with type arguments of type ReadResponse

Modifier and Type	Method and Description
ReadResponse	ReadResponseMarshaller.combineData(DataMessage<ReadResponse,DataBuffer> message)
io.grpc.stub.StreamObserver<ReadRequest>	BlockWorkerGrpc.BlockWorkerImplBase.readBlock(io.grpc.stub.StreamObserver<ReadResponse> responseObserver)
io.grpc.stub.StreamObserver<ReadRequest>	BlockWorkerGrpc.BlockWorkerStub.readBlock(io.grpc.stub.StreamObserver<ReadResponse> responseObserver)

Uses of ReadResponse in alluxio.worker.grpc

Method parameters in alluxio.worker.grpc with type arguments of type ReadResponse

Modifier and Type	Method and Description
protected alluxio.worker.grpc.AbstractReadHandler.DataReader	BlockReadHandler.createDataReader(BlockReadRequestContext context, io.grpc.stub.StreamObserver<ReadResponse> response)
io.grpc.stub.StreamObserver<ReadRequest>	BlockWorkerImpl.readBlock(io.grpc.stub.StreamObserver<ReadResponse> responseObserver)

Constructor parameters in alluxio.worker.grpc with type arguments of type ReadResponse

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