Package | Description |
---|---|
alluxio.grpc | |
alluxio.master.job | |
alluxio.worker.block | |
alluxio.worker.page |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<Block> |
Block.PARSER
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Block |
Block.Builder.build() |
Block |
Block.Builder.buildPartial() |
Block |
BlockStatusOrBuilder.getBlock()
required .alluxio.grpc.block.Block block = 1; |
Block |
BlockStatus.getBlock()
required .alluxio.grpc.block.Block block = 1; |
Block |
BlockStatus.Builder.getBlock()
required .alluxio.grpc.block.Block block = 1; |
Block |
LoadRequestOrBuilder.getBlocks(int index)
repeated .alluxio.grpc.block.Block blocks = 1; |
Block |
LoadRequest.getBlocks(int index)
repeated .alluxio.grpc.block.Block blocks = 1; |
Block |
LoadRequest.Builder.getBlocks(int index)
repeated .alluxio.grpc.block.Block blocks = 1; |
static Block |
Block.getDefaultInstance() |
Block |
Block.getDefaultInstanceForType() |
Block |
Block.Builder.getDefaultInstanceForType() |
static Block |
Block.parseDelimitedFrom(InputStream input) |
static Block |
Block.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Block |
Block.parseFrom(byte[] data) |
static Block |
Block.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Block |
Block.parseFrom(ByteBuffer data) |
static Block |
Block.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Block |
Block.parseFrom(com.google.protobuf.ByteString data) |
static Block |
Block.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Block |
Block.parseFrom(com.google.protobuf.CodedInputStream input) |
static Block |
Block.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Block |
Block.parseFrom(InputStream input) |
static Block |
Block.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
List<Block> |
LoadRequestOrBuilder.getBlocksList()
repeated .alluxio.grpc.block.Block blocks = 1; |
List<Block> |
LoadRequest.getBlocksList()
repeated .alluxio.grpc.block.Block blocks = 1; |
List<Block> |
LoadRequest.Builder.getBlocksList()
repeated .alluxio.grpc.block.Block blocks = 1; |
com.google.protobuf.Parser<Block> |
Block.getParserForType() |
static com.google.protobuf.Parser<Block> |
Block.parser() |
Modifier and Type | Method and Description |
---|---|
LoadRequest.Builder |
LoadRequest.Builder.addBlocks(Block value)
repeated .alluxio.grpc.block.Block blocks = 1; |
LoadRequest.Builder |
LoadRequest.Builder.addBlocks(int index,
Block value)
repeated .alluxio.grpc.block.Block blocks = 1; |
BlockStatus.Builder |
BlockStatus.Builder.mergeBlock(Block value)
required .alluxio.grpc.block.Block block = 1; |
Block.Builder |
Block.Builder.mergeFrom(Block other) |
static Block.Builder |
Block.newBuilder(Block prototype) |
BlockStatus.Builder |
BlockStatus.Builder.setBlock(Block value)
required .alluxio.grpc.block.Block block = 1; |
LoadRequest.Builder |
LoadRequest.Builder.setBlocks(int index,
Block value)
repeated .alluxio.grpc.block.Block blocks = 1; |
Modifier and Type | Method and Description |
---|---|
LoadRequest.Builder |
LoadRequest.Builder.addAllBlocks(Iterable<? extends Block> values)
repeated .alluxio.grpc.block.Block blocks = 1; |
Modifier and Type | Method and Description |
---|---|
List<Block> |
LoadJob.LoadTask.getBlocks() |
List<Block> |
LoadJob.getNextBatchBlocks(int count)
Get next batch of blocks.
|
Modifier and Type | Method and Description |
---|---|
void |
LoadJob.addBlockFailure(Block block,
String message,
int code)
Add a block to failure summary.
|
boolean |
LoadJob.addBlockToRetry(Block block)
Add a block to retry later.
|
Constructor and Description |
---|
LoadTask(List<Block> blocks)
Creates a new instance of
LoadJob.LoadTask . |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<List<BlockStatus>> |
MonoBlockStore.load(List<Block> blocks,
UfsReadOptions options) |
CompletableFuture<List<BlockStatus>> |
DefaultBlockWorker.load(List<Block> blocks,
UfsReadOptions options) |
CompletableFuture<List<BlockStatus>> |
BlockStore.load(List<Block> fileBlocks,
UfsReadOptions options)
Load blocks into alluxio.
|
CompletableFuture<List<BlockStatus>> |
BlockWorker.load(List<Block> fileBlocks,
UfsReadOptions options)
Load blocks into alluxio.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<List<BlockStatus>> |
PagedBlockStore.load(List<Block> fileBlocks,
UfsReadOptions options) |
Copyright © 2023. All Rights Reserved.