Package | Description |
---|---|
alluxio.client.block.stream | |
alluxio.client.file.dora.netty | |
alluxio.proto.dataserver |
Constructor and Description |
---|
Factory(FileSystemContext context,
WorkerNetAddress address,
Protocol.ReadRequest.Builder readRequestBuilder)
Creates an instance of
NettyDataReader.Factory for block reads. |
Constructor and Description |
---|
NettyDataReader(FileSystemContext context,
WorkerNetAddress address,
Protocol.ReadRequest.Builder requestBuilder)
Constructor.
|
NettyDataReaderStateMachine(FileSystemContext context,
WorkerNetAddress address,
Protocol.ReadRequest.Builder requestBuilder,
ReadTargetBuffer buffer)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.clear() |
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.clearBlockId()
optional int64 block_id = 1; |
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.clearCancel()
If set, this request is to cancel the reading request for the id.
|
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.clearChunkSize()
If set, the server should send packets in the specified packet size.
|
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.clearField(com.google.protobuf.Descriptors.FieldDescriptor field) |
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.clearLength()
optional int64 length = 3; |
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.clearOffset()
optional int64 offset = 2; |
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) |
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.clearOpenUfsBlockOptions()
This is only set for UFS block read.
|
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.clearPromote()
Whether the block should be promoted before reading
|
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.clone() |
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.mergeFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.mergeFrom(com.google.protobuf.Message other) |
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.mergeFrom(Protocol.ReadRequest other) |
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.mergeOpenUfsBlockOptions(Protocol.OpenUfsBlockOptions value)
This is only set for UFS block read.
|
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
static Protocol.ReadRequest.Builder |
Protocol.ReadRequest.newBuilder() |
static Protocol.ReadRequest.Builder |
Protocol.ReadRequest.newBuilder(Protocol.ReadRequest prototype) |
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.newBuilderForType() |
protected Protocol.ReadRequest.Builder |
Protocol.ReadRequest.newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) |
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.setBlockId(long value)
optional int64 block_id = 1; |
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.setCancel(boolean value)
If set, this request is to cancel the reading request for the id.
|
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.setChunkSize(long value)
If set, the server should send packets in the specified packet size.
|
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.setField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.setLength(long value)
optional int64 length = 3; |
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.setOffset(long value)
optional int64 offset = 2; |
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.setOpenUfsBlockOptions(Protocol.OpenUfsBlockOptions.Builder builderForValue)
This is only set for UFS block read.
|
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.setOpenUfsBlockOptions(Protocol.OpenUfsBlockOptions value)
This is only set for UFS block read.
|
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.setPromote(boolean value)
Whether the block should be promoted before reading
|
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
int index,
Object value) |
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.toBuilder() |
Copyright © 2023. All Rights Reserved.