Modifier and Type | Method and Description |
---|---|
protected GrpcDataReader.Factory |
DoraCacheClient.createGrpcDataReader(WorkerNetAddress workerNetAddress,
Protocol.OpenUfsBlockOptions ufsOptions) |
protected NettyDataReader |
DoraCacheClient.createNettyDataReader(WorkerNetAddress workerNetAddress,
Protocol.OpenUfsBlockOptions ufsOptions) |
DoraCachePositionReader |
DoraCacheClient.createNettyPositionReader(URIStatus status,
Protocol.OpenUfsBlockOptions ufsOptions,
Optional<CloseableSupplier<PositionReader>> externalPositionReader) |
PositionReadFileInStream |
DoraCacheClient.getInStream(URIStatus status,
Protocol.OpenUfsBlockOptions ufsOptions)
Get a stream to read the data from dora cache cluster.
|
Modifier and Type | Method and Description |
---|---|
Protocol.OpenUfsBlockOptions |
InStreamOptions.getOpenUfsBlockOptions(long blockId) |
Modifier and Type | Method and Description |
---|---|
Protocol.OpenUfsBlockOptions |
ReadRequestOrBuilder.getOpenUfsBlockOptions()
This is only set for UFS block read.
|
Protocol.OpenUfsBlockOptions |
ReadRequest.getOpenUfsBlockOptions()
This is only set for UFS block read.
|
Protocol.OpenUfsBlockOptions |
ReadRequest.Builder.getOpenUfsBlockOptions()
This is only set for UFS block read.
|
Protocol.OpenUfsBlockOptions |
AsyncCacheRequest.getOpenUfsBlockOptions()
optional .alluxio.proto.dataserver.OpenUfsBlockOptions open_ufs_block_options = 4; |
Protocol.OpenUfsBlockOptions |
AsyncCacheRequest.Builder.getOpenUfsBlockOptions()
optional .alluxio.proto.dataserver.OpenUfsBlockOptions open_ufs_block_options = 4; |
Protocol.OpenUfsBlockOptions |
CacheRequestOrBuilder.getOpenUfsBlockOptions()
optional .alluxio.proto.dataserver.OpenUfsBlockOptions open_ufs_block_options = 4; |
Protocol.OpenUfsBlockOptions |
CacheRequest.getOpenUfsBlockOptions()
optional .alluxio.proto.dataserver.OpenUfsBlockOptions open_ufs_block_options = 4; |
Protocol.OpenUfsBlockOptions |
CacheRequest.Builder.getOpenUfsBlockOptions()
optional .alluxio.proto.dataserver.OpenUfsBlockOptions open_ufs_block_options = 4; |
Protocol.OpenUfsBlockOptions |
AsyncCacheRequestOrBuilder.getOpenUfsBlockOptions()
optional .alluxio.proto.dataserver.OpenUfsBlockOptions open_ufs_block_options = 4; |
Modifier and Type | Method and Description |
---|---|
ReadRequest.Builder |
ReadRequest.Builder.mergeOpenUfsBlockOptions(Protocol.OpenUfsBlockOptions value)
This is only set for UFS block read.
|
AsyncCacheRequest.Builder |
AsyncCacheRequest.Builder.mergeOpenUfsBlockOptions(Protocol.OpenUfsBlockOptions value)
optional .alluxio.proto.dataserver.OpenUfsBlockOptions open_ufs_block_options = 4; |
CacheRequest.Builder |
CacheRequest.Builder.mergeOpenUfsBlockOptions(Protocol.OpenUfsBlockOptions value)
optional .alluxio.proto.dataserver.OpenUfsBlockOptions open_ufs_block_options = 4; |
ReadRequest.Builder |
ReadRequest.Builder.setOpenUfsBlockOptions(Protocol.OpenUfsBlockOptions value)
This is only set for UFS block read.
|
AsyncCacheRequest.Builder |
AsyncCacheRequest.Builder.setOpenUfsBlockOptions(Protocol.OpenUfsBlockOptions value)
optional .alluxio.proto.dataserver.OpenUfsBlockOptions open_ufs_block_options = 4; |
CacheRequest.Builder |
CacheRequest.Builder.setOpenUfsBlockOptions(Protocol.OpenUfsBlockOptions value)
optional .alluxio.proto.dataserver.OpenUfsBlockOptions open_ufs_block_options = 4; |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<Protocol.OpenUfsBlockOptions> |
Protocol.OpenUfsBlockOptions.PARSER
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Protocol.OpenUfsBlockOptions |
Protocol.OpenUfsBlockOptions.Builder.build() |
Protocol.OpenUfsBlockOptions |
Protocol.OpenUfsBlockOptions.Builder.buildPartial() |
static Protocol.OpenUfsBlockOptions |
Protocol.OpenUfsBlockOptions.getDefaultInstance() |
Protocol.OpenUfsBlockOptions |
Protocol.OpenUfsBlockOptions.getDefaultInstanceForType() |
Protocol.OpenUfsBlockOptions |
Protocol.OpenUfsBlockOptions.Builder.getDefaultInstanceForType() |
Protocol.OpenUfsBlockOptions |
Protocol.ReadRequestOrBuilder.getOpenUfsBlockOptions()
This is only set for UFS block read.
|
Protocol.OpenUfsBlockOptions |
Protocol.ReadRequest.getOpenUfsBlockOptions()
This is only set for UFS block read.
|
Protocol.OpenUfsBlockOptions |
Protocol.ReadRequest.Builder.getOpenUfsBlockOptions()
This is only set for UFS block read.
|
Protocol.OpenUfsBlockOptions |
Protocol.AsyncCacheRequestOrBuilder.getOpenUfsBlockOptions()
optional .alluxio.proto.dataserver.OpenUfsBlockOptions open_ufs_block_options = 4; |
Protocol.OpenUfsBlockOptions |
Protocol.AsyncCacheRequest.getOpenUfsBlockOptions()
optional .alluxio.proto.dataserver.OpenUfsBlockOptions open_ufs_block_options = 4; |
Protocol.OpenUfsBlockOptions |
Protocol.AsyncCacheRequest.Builder.getOpenUfsBlockOptions()
optional .alluxio.proto.dataserver.OpenUfsBlockOptions open_ufs_block_options = 4; |
static Protocol.OpenUfsBlockOptions |
Protocol.OpenUfsBlockOptions.parseDelimitedFrom(InputStream input) |
static Protocol.OpenUfsBlockOptions |
Protocol.OpenUfsBlockOptions.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Protocol.OpenUfsBlockOptions |
Protocol.OpenUfsBlockOptions.parseFrom(byte[] data) |
static Protocol.OpenUfsBlockOptions |
Protocol.OpenUfsBlockOptions.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Protocol.OpenUfsBlockOptions |
Protocol.OpenUfsBlockOptions.parseFrom(ByteBuffer data) |
static Protocol.OpenUfsBlockOptions |
Protocol.OpenUfsBlockOptions.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Protocol.OpenUfsBlockOptions |
Protocol.OpenUfsBlockOptions.parseFrom(com.google.protobuf.ByteString data) |
static Protocol.OpenUfsBlockOptions |
Protocol.OpenUfsBlockOptions.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Protocol.OpenUfsBlockOptions |
Protocol.OpenUfsBlockOptions.parseFrom(com.google.protobuf.CodedInputStream input) |
static Protocol.OpenUfsBlockOptions |
Protocol.OpenUfsBlockOptions.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Protocol.OpenUfsBlockOptions |
Protocol.OpenUfsBlockOptions.parseFrom(InputStream input) |
static Protocol.OpenUfsBlockOptions |
Protocol.OpenUfsBlockOptions.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<Protocol.OpenUfsBlockOptions> |
Protocol.OpenUfsBlockOptions.getParserForType() |
static com.google.protobuf.Parser<Protocol.OpenUfsBlockOptions> |
Protocol.OpenUfsBlockOptions.parser() |
Modifier and Type | Method and Description |
---|---|
Protocol.OpenUfsBlockOptions.Builder |
Protocol.OpenUfsBlockOptions.Builder.mergeFrom(Protocol.OpenUfsBlockOptions other) |
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.mergeOpenUfsBlockOptions(Protocol.OpenUfsBlockOptions value)
This is only set for UFS block read.
|
Protocol.AsyncCacheRequest.Builder |
Protocol.AsyncCacheRequest.Builder.mergeOpenUfsBlockOptions(Protocol.OpenUfsBlockOptions value)
optional .alluxio.proto.dataserver.OpenUfsBlockOptions open_ufs_block_options = 4; |
static Protocol.OpenUfsBlockOptions.Builder |
Protocol.OpenUfsBlockOptions.newBuilder(Protocol.OpenUfsBlockOptions prototype) |
Protocol.ReadRequest.Builder |
Protocol.ReadRequest.Builder.setOpenUfsBlockOptions(Protocol.OpenUfsBlockOptions value)
This is only set for UFS block read.
|
Protocol.AsyncCacheRequest.Builder |
Protocol.AsyncCacheRequest.Builder.setOpenUfsBlockOptions(Protocol.OpenUfsBlockOptions value)
optional .alluxio.proto.dataserver.OpenUfsBlockOptions open_ufs_block_options = 4; |
Modifier and Type | Method and Description |
---|---|
Protocol.OpenUfsBlockOptions |
BlockReadRequest.getOpenUfsBlockOptions() |
Modifier and Type | Method and Description |
---|---|
BlockReader |
BlockStore.createBlockReader(long sessionId,
long blockId,
long offset,
boolean positionShort,
Protocol.OpenUfsBlockOptions options)
Creates the block reader to read from Alluxio block or UFS block.
|
BlockReader |
BlockWorker.createBlockReader(long sessionId,
long blockId,
long offset,
boolean positionShort,
Protocol.OpenUfsBlockOptions options)
Creates the block reader to read from Alluxio block or UFS block.
|
BlockReader |
BlockStore.createUfsBlockReader(long sessionId,
long blockId,
long offset,
boolean positionShort,
Protocol.OpenUfsBlockOptions options)
Creates a block reader to read a UFS block starting from given block offset.
|
BlockReader |
BlockWorker.createUfsBlockReader(long sessionId,
long blockId,
long offset,
boolean positionShort,
Protocol.OpenUfsBlockOptions options)
Creates a block reader to read a UFS block starting from given block offset.
|
boolean |
BlockWorker.openUfsBlock(long sessionId,
long blockId,
Protocol.OpenUfsBlockOptions options)
Opens a UFS block.
|
Modifier and Type | Method and Description |
---|---|
BlockReader |
PagedDoraWorker.createFileReader(String fileId,
long offset,
boolean positionShort,
Protocol.OpenUfsBlockOptions options) |
BlockReader |
DoraWorker.createFileReader(String fileId,
long offset,
boolean positionShort,
Protocol.OpenUfsBlockOptions options)
Creates the file reader to read from Alluxio dora.
|
Modifier and Type | Method and Description |
---|---|
Protocol.OpenUfsBlockOptions |
BlockReadRequest.getOpenUfsBlockOptions() |
Copyright © 2023. All Rights Reserved.