Package | Description |
---|---|
alluxio.client.block.stream | |
alluxio.grpc |
Constructor and Description |
---|
Factory(FileSystemContext context,
WorkerNetAddress address,
ReadRequest.Builder readRequestBuilder)
Creates an instance of
GrpcDataReader.Factory for block reads. |
Factory(FileSystemContext context,
WorkerNetAddress address,
ReadRequest.Builder readRequestBuilder,
long blockSize)
Creates an instance of
SharedGrpcDataReader.Factory for block reads. |
Modifier and Type | Method and Description |
---|---|
ReadRequest.Builder |
ReadRequest.Builder.addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
ReadRequest.Builder |
ReadRequest.Builder.clear() |
ReadRequest.Builder |
ReadRequest.Builder.clearBlockId()
optional int64 block_id = 1; |
ReadRequest.Builder |
ReadRequest.Builder.clearChunkSize()
optional int64 chunk_size = 5; |
ReadRequest.Builder |
ReadRequest.Builder.clearField(com.google.protobuf.Descriptors.FieldDescriptor field) |
ReadRequest.Builder |
ReadRequest.Builder.clearLength()
optional int64 length = 3; |
ReadRequest.Builder |
ReadRequest.Builder.clearOffset()
optional int64 offset = 2; |
ReadRequest.Builder |
ReadRequest.Builder.clearOffsetReceived()
Read receipt
|
ReadRequest.Builder |
ReadRequest.Builder.clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) |
ReadRequest.Builder |
ReadRequest.Builder.clearOpenUfsBlockOptions()
This is only set for UFS block read.
|
ReadRequest.Builder |
ReadRequest.Builder.clearPositionShort()
Is position read to a small buffer
|
ReadRequest.Builder |
ReadRequest.Builder.clearPromote()
Whether the block should be promoted before reading
|
ReadRequest.Builder |
ReadRequest.Builder.clone() |
ReadRequest.Builder |
ReadRequest.Builder.mergeFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
ReadRequest.Builder |
ReadRequest.Builder.mergeFrom(com.google.protobuf.Message other) |
ReadRequest.Builder |
ReadRequest.Builder.mergeFrom(ReadRequest other) |
ReadRequest.Builder |
ReadRequest.Builder.mergeOpenUfsBlockOptions(Protocol.OpenUfsBlockOptions value)
This is only set for UFS block read.
|
ReadRequest.Builder |
ReadRequest.Builder.mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
static ReadRequest.Builder |
ReadRequest.newBuilder() |
static ReadRequest.Builder |
ReadRequest.newBuilder(ReadRequest prototype) |
ReadRequest.Builder |
ReadRequest.newBuilderForType() |
protected ReadRequest.Builder |
ReadRequest.newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) |
ReadRequest.Builder |
ReadRequest.Builder.setBlockId(long value)
optional int64 block_id = 1; |
ReadRequest.Builder |
ReadRequest.Builder.setChunkSize(long value)
optional int64 chunk_size = 5; |
ReadRequest.Builder |
ReadRequest.Builder.setField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
ReadRequest.Builder |
ReadRequest.Builder.setLength(long value)
optional int64 length = 3; |
ReadRequest.Builder |
ReadRequest.Builder.setOffset(long value)
optional int64 offset = 2; |
ReadRequest.Builder |
ReadRequest.Builder.setOffsetReceived(long value)
Read receipt
|
ReadRequest.Builder |
ReadRequest.Builder.setOpenUfsBlockOptions(Protocol.OpenUfsBlockOptions.Builder builderForValue)
This is only set for UFS block read.
|
ReadRequest.Builder |
ReadRequest.Builder.setOpenUfsBlockOptions(Protocol.OpenUfsBlockOptions value)
This is only set for UFS block read.
|
ReadRequest.Builder |
ReadRequest.Builder.setPositionShort(boolean value)
Is position read to a small buffer
|
ReadRequest.Builder |
ReadRequest.Builder.setPromote(boolean value)
Whether the block should be promoted before reading
|
ReadRequest.Builder |
ReadRequest.Builder.setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
int index,
Object value) |
ReadRequest.Builder |
ReadRequest.Builder.setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
ReadRequest.Builder |
ReadRequest.toBuilder() |
Copyright © 2023. All Rights Reserved.