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 |
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.
|
Protocol.OpenUfsBlockOptions |
AsyncCacheRequestOrBuilder.getOpenUfsBlockOptions()
optional .alluxio.proto.dataserver.OpenUfsBlockOptions open_ufs_block_options = 4; |
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() |
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 |
MonoBlockStore.createBlockReader(long sessionId,
long blockId,
long offset,
boolean positionShort,
Protocol.OpenUfsBlockOptions options) |
BlockReader |
UnderFileSystemBlockStore.createBlockReader(long sessionId,
long blockId,
long offset,
boolean positionShort,
Protocol.OpenUfsBlockOptions options)
Creates a block reader that reads from UFS and optionally caches the block to the Alluxio
block store.
|
BlockReader |
DefaultBlockWorker.createBlockReader(long sessionId,
long blockId,
long offset,
boolean positionShort,
Protocol.OpenUfsBlockOptions options)
Closes a UFS block for a client session.
|
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.createBlockReader(long sessionId,
long blockId,
long offset,
boolean positionShort,
Protocol.OpenUfsBlockOptions options)
Creates the block reader to read from Alluxio block or UFS block.
|
default BlockReader |
LocalBlockStore.createBlockReader(long sessionId,
long blockId,
Protocol.OpenUfsBlockOptions options)
Creates a reader of an existing block to read data from this block.
|
BlockReader |
MonoBlockStore.createUfsBlockReader(long sessionId,
long blockId,
long offset,
boolean positionShort,
Protocol.OpenUfsBlockOptions options) |
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.
|
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.
|
RemoteBlockReader |
CacheRequestManager.getRemoteBlockReader(long blockId,
long blockSize,
InetSocketAddress sourceAddress,
Protocol.OpenUfsBlockOptions openUfsBlockOptions)
only public to test since we want to mock remoteBlockReader.
|
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 |
---|---|
BlockReader |
PagedBlockStore.createBlockReader(long sessionId,
long blockId,
long offset,
boolean positionShort,
Protocol.OpenUfsBlockOptions options) |
BlockReader |
PagedBlockStore.createUfsBlockReader(long sessionId,
long blockId,
long offset,
boolean positionShort,
Protocol.OpenUfsBlockOptions options) |
static UfsBlockReadOptions |
UfsBlockReadOptions.fromProto(Protocol.OpenUfsBlockOptions options)
Creates from wire object.
|
Copyright © 2023. All Rights Reserved.