Package | Description |
---|---|
alluxio.grpc | |
alluxio.underfs | |
alluxio.worker.block | |
alluxio.worker.dora |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<UfsReadOptions> |
UfsReadOptions.PARSER
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
UfsReadOptions |
UfsReadOptions.Builder.build() |
UfsReadOptions |
UfsReadOptions.Builder.buildPartial() |
static UfsReadOptions |
UfsReadOptions.getDefaultInstance() |
UfsReadOptions |
UfsReadOptions.getDefaultInstanceForType() |
UfsReadOptions |
UfsReadOptions.Builder.getDefaultInstanceForType() |
UfsReadOptions |
LoadFileRequest.getOptions()
required .alluxio.grpc.block.UfsReadOptions options = 2; |
UfsReadOptions |
LoadFileRequest.Builder.getOptions()
required .alluxio.grpc.block.UfsReadOptions options = 2; |
UfsReadOptions |
LoadRequest.getOptions()
required .alluxio.grpc.block.UfsReadOptions options = 2; |
UfsReadOptions |
LoadRequest.Builder.getOptions()
required .alluxio.grpc.block.UfsReadOptions options = 2; |
UfsReadOptions |
LoadFileRequestOrBuilder.getOptions()
required .alluxio.grpc.block.UfsReadOptions options = 2; |
UfsReadOptions |
LoadRequestOrBuilder.getOptions()
required .alluxio.grpc.block.UfsReadOptions options = 2; |
UfsReadOptions |
CopyRequest.getUfsReadOptions()
optional .alluxio.grpc.block.UfsReadOptions ufs_read_options = 2; |
UfsReadOptions |
CopyRequest.Builder.getUfsReadOptions()
optional .alluxio.grpc.block.UfsReadOptions ufs_read_options = 2; |
UfsReadOptions |
CopyRequestOrBuilder.getUfsReadOptions()
optional .alluxio.grpc.block.UfsReadOptions ufs_read_options = 2; |
UfsReadOptions |
MoveRequestOrBuilder.getUfsReadOptions()
optional .alluxio.grpc.block.UfsReadOptions ufs_read_options = 2; |
UfsReadOptions |
MoveRequest.getUfsReadOptions()
optional .alluxio.grpc.block.UfsReadOptions ufs_read_options = 2; |
UfsReadOptions |
MoveRequest.Builder.getUfsReadOptions()
optional .alluxio.grpc.block.UfsReadOptions ufs_read_options = 2; |
static UfsReadOptions |
UfsReadOptions.parseDelimitedFrom(InputStream input) |
static UfsReadOptions |
UfsReadOptions.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static UfsReadOptions |
UfsReadOptions.parseFrom(byte[] data) |
static UfsReadOptions |
UfsReadOptions.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static UfsReadOptions |
UfsReadOptions.parseFrom(ByteBuffer data) |
static UfsReadOptions |
UfsReadOptions.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static UfsReadOptions |
UfsReadOptions.parseFrom(com.google.protobuf.ByteString data) |
static UfsReadOptions |
UfsReadOptions.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static UfsReadOptions |
UfsReadOptions.parseFrom(com.google.protobuf.CodedInputStream input) |
static UfsReadOptions |
UfsReadOptions.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static UfsReadOptions |
UfsReadOptions.parseFrom(InputStream input) |
static UfsReadOptions |
UfsReadOptions.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<UfsReadOptions> |
UfsReadOptions.getParserForType() |
static com.google.protobuf.Parser<UfsReadOptions> |
UfsReadOptions.parser() |
Modifier and Type | Method and Description |
---|---|
UfsReadOptions.Builder |
UfsReadOptions.Builder.mergeFrom(UfsReadOptions other) |
LoadFileRequest.Builder |
LoadFileRequest.Builder.mergeOptions(UfsReadOptions value)
required .alluxio.grpc.block.UfsReadOptions options = 2; |
LoadRequest.Builder |
LoadRequest.Builder.mergeOptions(UfsReadOptions value)
required .alluxio.grpc.block.UfsReadOptions options = 2; |
CopyRequest.Builder |
CopyRequest.Builder.mergeUfsReadOptions(UfsReadOptions value)
optional .alluxio.grpc.block.UfsReadOptions ufs_read_options = 2; |
MoveRequest.Builder |
MoveRequest.Builder.mergeUfsReadOptions(UfsReadOptions value)
optional .alluxio.grpc.block.UfsReadOptions ufs_read_options = 2; |
static UfsReadOptions.Builder |
UfsReadOptions.newBuilder(UfsReadOptions prototype) |
LoadFileRequest.Builder |
LoadFileRequest.Builder.setOptions(UfsReadOptions value)
required .alluxio.grpc.block.UfsReadOptions options = 2; |
LoadRequest.Builder |
LoadRequest.Builder.setOptions(UfsReadOptions value)
required .alluxio.grpc.block.UfsReadOptions options = 2; |
CopyRequest.Builder |
CopyRequest.Builder.setUfsReadOptions(UfsReadOptions value)
optional .alluxio.grpc.block.UfsReadOptions ufs_read_options = 2; |
MoveRequest.Builder |
MoveRequest.Builder.setUfsReadOptions(UfsReadOptions value)
optional .alluxio.grpc.block.UfsReadOptions ufs_read_options = 2; |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Integer> |
UfsIOManager.read(ByteBuffer buf,
long offset,
long len,
FileId fileId,
String ufsPath,
UfsReadOptions options)
Read from ufs.
|
Modifier and Type | Method and Description |
---|---|
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 |
---|---|
com.google.common.util.concurrent.ListenableFuture<List<RouteFailure>> |
PagedDoraWorker.copy(List<Route> routes,
UfsReadOptions readOptions,
WriteOptions writeOptions) |
com.google.common.util.concurrent.ListenableFuture<List<RouteFailure>> |
DoraWorker.copy(List<Route> routes,
UfsReadOptions readOptions,
WriteOptions writeOptions)
Copies files from src to dst.
|
com.google.common.util.concurrent.ListenableFuture<LoadFileResponse> |
PagedDoraWorker.load(boolean loadData,
boolean skipIfExists,
List<UfsStatus> ufsStatuses,
UfsReadOptions options) |
com.google.common.util.concurrent.ListenableFuture<LoadFileResponse> |
DoraWorker.load(boolean loadData,
boolean skipIfExists,
List<UfsStatus> ufsStatuses,
UfsReadOptions options)
Loads the metadata and data of files from UFS to Alluxio.
|
com.google.common.util.concurrent.ListenableFuture<List<RouteFailure>> |
PagedDoraWorker.move(List<Route> routes,
UfsReadOptions readOptions,
WriteOptions writeOptions) |
com.google.common.util.concurrent.ListenableFuture<List<RouteFailure>> |
DoraWorker.move(List<Route> routes,
UfsReadOptions readOptions,
WriteOptions writeOptions)
Moves files from src to dst.
|
Copyright © 2023. All Rights Reserved.