Package | Description |
---|---|
alluxio.client.block.stream | |
alluxio.client.file.options | |
alluxio.proto.dataserver | |
alluxio.worker.block | |
alluxio.worker.block.meta | |
alluxio.worker.netty |
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 | Field and Description |
---|---|
static com.google.protobuf.Parser<Protocol.OpenUfsBlockOptions> |
Protocol.OpenUfsBlockOptions.PARSER |
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()
optional .alluxio.proto.dataserver.OpenUfsBlockOptions open_ufs_block_options = 6; |
Protocol.OpenUfsBlockOptions |
Protocol.ReadRequest.getOpenUfsBlockOptions()
optional .alluxio.proto.dataserver.OpenUfsBlockOptions open_ufs_block_options = 6; |
Protocol.OpenUfsBlockOptions |
Protocol.ReadRequest.Builder.getOpenUfsBlockOptions()
optional .alluxio.proto.dataserver.OpenUfsBlockOptions open_ufs_block_options = 6; |
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(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() |
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)
optional .alluxio.proto.dataserver.OpenUfsBlockOptions open_ufs_block_options = 6; |
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)
optional .alluxio.proto.dataserver.OpenUfsBlockOptions open_ufs_block_options = 6; |
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 |
---|---|
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 |
DefaultBlockWorker.openUfsBlock(long sessionId,
long blockId,
Protocol.OpenUfsBlockOptions options) |
boolean |
BlockWorker.openUfsBlock(long sessionId,
long blockId,
Protocol.OpenUfsBlockOptions options)
Opens a UFS block.
|
Constructor and Description |
---|
RemoteBlockReader(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.