Package | Description |
---|---|
alluxio.client.block.stream | |
alluxio.client.file.options | |
alluxio.grpc | |
alluxio.proto.dataserver | |
alluxio.wire | |
alluxio.worker.block | |
alluxio.worker.block.meta |
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 |
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; |
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 |
---|---|
CacheRequest.Builder |
CacheRequest.Builder.mergeOpenUfsBlockOptions(Protocol.OpenUfsBlockOptions value)
optional .alluxio.proto.dataserver.OpenUfsBlockOptions open_ufs_block_options = 4; |
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.
|
CacheRequest.Builder |
CacheRequest.Builder.setOpenUfsBlockOptions(Protocol.OpenUfsBlockOptions value)
optional .alluxio.proto.dataserver.OpenUfsBlockOptions open_ufs_block_options = 4; |
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 |
---|---|
Protocol.OpenUfsBlockOptions |
BlockReadRequest.getOpenUfsBlockOptions() |
Constructor and Description |
---|
BlockReadRequest(long id,
long start,
long end,
long chunkSize,
boolean promote,
boolean positionShort,
Protocol.OpenUfsBlockOptions openUfsBlockOptions)
Creates an instance of
BlockReadRequest . |
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. |
BlockReader |
DefaultBlockWorker.createUfsBlockReader(long sessionId,
long blockId,
long offset,
boolean positionShort,
Protocol.OpenUfsBlockOptions options) |
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.
|
RemoteBlockReader |
CacheRequestManager.getRemoteBlockReader(long blockId,
long blockSize,
InetSocketAddress sourceAddress,
Protocol.OpenUfsBlockOptions openUfsBlockOptions)
only public to test since we want to mock remoteBlockReader.
|
boolean |
DefaultBlockWorker.openUfsBlock(long sessionId,
long blockId,
Protocol.OpenUfsBlockOptions options)
Opens a UFS block.
|
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 . |
Copyright © 2023. All Rights Reserved.