Uses of Class
alluxio.grpc.WriteRequest

Packages that use WriteRequest

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

Uses of WriteRequest in alluxio.client.block.stream

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

Modifier and Type	Method and Description
io.grpc.stub.StreamObserver<WriteRequest>	DefaultBlockWorkerClient.writeBlock(io.grpc.stub.StreamObserver<WriteResponse> responseObserver)
io.grpc.stub.StreamObserver<WriteRequest>	BlockWorkerClient.writeBlock(io.grpc.stub.StreamObserver<WriteResponse> responseObserver) Writes a block to the worker asynchronously.

Uses of WriteRequest in alluxio.grpc

Fields in alluxio.grpc with type parameters of type WriteRequest

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

Methods in alluxio.grpc that return WriteRequest

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

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

Modifier and Type	Method and Description
com.google.protobuf.Parser<WriteRequest>	WriteRequest.getParserForType()
static io.grpc.MethodDescriptor<WriteRequest,WriteResponse>	BlockWorkerGrpc.getWriteBlockMethod()
static com.google.protobuf.Parser<WriteRequest>	WriteRequest.parser()
io.grpc.stub.StreamObserver<WriteRequest>	BlockWorkerGrpc.BlockWorkerImplBase.writeBlock(io.grpc.stub.StreamObserver<WriteResponse> responseObserver)
io.grpc.stub.StreamObserver<WriteRequest>	BlockWorkerGrpc.BlockWorkerStub.writeBlock(io.grpc.stub.StreamObserver<WriteResponse> responseObserver)

Methods in alluxio.grpc with parameters of type WriteRequest

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

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

Modifier and Type	Method and Description
WriteRequest	WriteRequestMarshaller.combineData(DataMessage<WriteRequest,DataBuffer> message)

Uses of WriteRequest in alluxio.worker.grpc

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

Modifier and Type	Method and Description
io.grpc.stub.StreamObserver<WriteRequest>	BlockWorkerClientServiceHandler.writeBlock(io.grpc.stub.StreamObserver<WriteResponse> responseObserver)

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

Modifier and Type	Method and Description
protected BlockWriteRequestContext	BlockWriteHandler.createRequestContext(WriteRequest msg)
protected BlockWriteRequestContext	UfsFallbackBlockWriteHandler.createRequestContext(WriteRequest msg)
protected UfsFileWriteRequestContext	UfsFileWriteHandler.createRequestContext(WriteRequest msg)
void	DelegationWriteHandler.onNext(WriteRequest request)