Modifier and Type | Method and Description |
---|---|
static BlockInStream |
BlockInStream.createRemoteBlockInStream(FileSystemContext context,
long blockId,
WorkerNetAddress address,
BlockInStream.BlockInStreamSource blockSource,
long blockSize,
Protocol.OpenUfsBlockOptions ufsOptions)
Creates a
BlockInStream to read from a specific remote server. |
Modifier and Type | Method and Description |
---|---|
Protocol.OpenUfsBlockOptions |
InStreamOptions.getOpenUfsBlockOptions(long blockId) |
Modifier and Type | Method and Description |
---|---|
Protocol.OpenUfsBlockOptions |
AsyncCacheRequestOrBuilder.getOpenUfsBlockOptions()
optional .alluxio.proto.dataserver.OpenUfsBlockOptions open_ufs_block_options = 4; |
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 |
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 |
ReadRequestOrBuilder.getOpenUfsBlockOptions()
This is only set for UFS block read.
|
Modifier and Type | Method and Description |
---|---|
AsyncCacheRequest.Builder |
AsyncCacheRequest.Builder.mergeOpenUfsBlockOptions(Protocol.OpenUfsBlockOptions value)
optional .alluxio.proto.dataserver.OpenUfsBlockOptions open_ufs_block_options = 4; |
ReadRequest.Builder |
ReadRequest.Builder.mergeOpenUfsBlockOptions(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; |
ReadRequest.Builder |
ReadRequest.Builder.setOpenUfsBlockOptions(Protocol.OpenUfsBlockOptions value)
This is only set for UFS block read.
|
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() |
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) |
static Protocol.OpenUfsBlockOptions.Builder |
Protocol.OpenUfsBlockOptions.newBuilder(Protocol.OpenUfsBlockOptions prototype) |
Modifier and Type | Method and Description |
---|---|
boolean |
UnderFileSystemBlockStore.acquireAccess(long sessionId,
long blockId,
Protocol.OpenUfsBlockOptions options)
Acquires access for a UFS block given a
UnderFileSystemBlockMeta and the limit on
the maximum concurrency on the block. |
boolean |
BlockWorker.openUfsBlock(long sessionId,
long blockId,
Protocol.OpenUfsBlockOptions options)
Opens a UFS block.
|
boolean |
DefaultBlockWorker.openUfsBlock(long sessionId,
long blockId,
Protocol.OpenUfsBlockOptions options) |
Constructor and Description |
---|
RemoteBlockReader(FileSystemContext fsContext,
long blockId,
long blockSize,
InetSocketAddress dataSource,
Protocol.OpenUfsBlockOptions ufsOptions)
Constructs a remote block reader.
|
Constructor and Description |
---|
UnderFileSystemBlockMeta(long sessionId,
long blockId,
Protocol.OpenUfsBlockOptions options)
Creates an instance of
UnderFileSystemBlockMeta . |
Modifier and Type | Method and Description |
---|---|
Protocol.OpenUfsBlockOptions |
BlockReadRequest.getOpenUfsBlockOptions() |
Copyright © 2023. All Rights Reserved.