Package | Description |
---|---|
alluxio.grpc | |
alluxio.master.job | |
alluxio.worker.dora | |
alluxio.worker.task |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<Route> |
Route.PARSER
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Route |
Route.Builder.build() |
Route |
Route.Builder.buildPartial() |
static Route |
Route.getDefaultInstance() |
Route |
Route.getDefaultInstanceForType() |
Route |
Route.Builder.getDefaultInstanceForType() |
Route |
RouteFailureOrBuilder.getRoute()
required .alluxio.grpc.block.Route route = 1; |
Route |
RouteFailure.getRoute()
required .alluxio.grpc.block.Route route = 1; |
Route |
RouteFailure.Builder.getRoute()
required .alluxio.grpc.block.Route route = 1; |
Route |
CopyRequest.getRoutes(int index)
repeated .alluxio.grpc.block.Route routes = 1; |
Route |
CopyRequest.Builder.getRoutes(int index)
repeated .alluxio.grpc.block.Route routes = 1; |
Route |
CopyRequestOrBuilder.getRoutes(int index)
repeated .alluxio.grpc.block.Route routes = 1; |
Route |
MoveRequestOrBuilder.getRoutes(int index)
repeated .alluxio.grpc.block.Route routes = 1; |
Route |
MoveRequest.getRoutes(int index)
repeated .alluxio.grpc.block.Route routes = 1; |
Route |
MoveRequest.Builder.getRoutes(int index)
repeated .alluxio.grpc.block.Route routes = 1; |
static Route |
Route.parseDelimitedFrom(InputStream input) |
static Route |
Route.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Route |
Route.parseFrom(byte[] data) |
static Route |
Route.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Route |
Route.parseFrom(ByteBuffer data) |
static Route |
Route.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Route |
Route.parseFrom(com.google.protobuf.ByteString data) |
static Route |
Route.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Route |
Route.parseFrom(com.google.protobuf.CodedInputStream input) |
static Route |
Route.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Route |
Route.parseFrom(InputStream input) |
static Route |
Route.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<Route> |
Route.getParserForType() |
List<Route> |
CopyRequest.getRoutesList()
repeated .alluxio.grpc.block.Route routes = 1; |
List<Route> |
CopyRequest.Builder.getRoutesList()
repeated .alluxio.grpc.block.Route routes = 1; |
List<Route> |
CopyRequestOrBuilder.getRoutesList()
repeated .alluxio.grpc.block.Route routes = 1; |
List<Route> |
MoveRequestOrBuilder.getRoutesList()
repeated .alluxio.grpc.block.Route routes = 1; |
List<Route> |
MoveRequest.getRoutesList()
repeated .alluxio.grpc.block.Route routes = 1; |
List<Route> |
MoveRequest.Builder.getRoutesList()
repeated .alluxio.grpc.block.Route routes = 1; |
static com.google.protobuf.Parser<Route> |
Route.parser() |
Modifier and Type | Method and Description |
---|---|
CopyRequest.Builder |
CopyRequest.Builder.addRoutes(int index,
Route value)
repeated .alluxio.grpc.block.Route routes = 1; |
MoveRequest.Builder |
MoveRequest.Builder.addRoutes(int index,
Route value)
repeated .alluxio.grpc.block.Route routes = 1; |
CopyRequest.Builder |
CopyRequest.Builder.addRoutes(Route value)
repeated .alluxio.grpc.block.Route routes = 1; |
MoveRequest.Builder |
MoveRequest.Builder.addRoutes(Route value)
repeated .alluxio.grpc.block.Route routes = 1; |
Route.Builder |
Route.Builder.mergeFrom(Route other) |
RouteFailure.Builder |
RouteFailure.Builder.mergeRoute(Route value)
required .alluxio.grpc.block.Route route = 1; |
static Route.Builder |
Route.newBuilder(Route prototype) |
RouteFailure.Builder |
RouteFailure.Builder.setRoute(Route value)
required .alluxio.grpc.block.Route route = 1; |
CopyRequest.Builder |
CopyRequest.Builder.setRoutes(int index,
Route value)
repeated .alluxio.grpc.block.Route routes = 1; |
MoveRequest.Builder |
MoveRequest.Builder.setRoutes(int index,
Route value)
repeated .alluxio.grpc.block.Route routes = 1; |
Modifier and Type | Method and Description |
---|---|
CopyRequest.Builder |
CopyRequest.Builder.addAllRoutes(Iterable<? extends Route> values)
repeated .alluxio.grpc.block.Route routes = 1; |
MoveRequest.Builder |
MoveRequest.Builder.addAllRoutes(Iterable<? extends Route> values)
repeated .alluxio.grpc.block.Route routes = 1; |
Modifier and Type | Method and Description |
---|---|
List<Route> |
CopyJob.getNextRoutes(int count)
Get next batch of blocks.
|
List<Route> |
MoveJob.getNextRoutes(int count)
Get next batch of blocks.
|
List<Route> |
CopyJob.CopyTask.getRoutes() |
List<Route> |
MoveJob.MoveTask.getRoutes() |
Modifier and Type | Method and Description |
---|---|
boolean |
CopyJob.addToRetry(Route route)
Add a route to retry later.
|
boolean |
MoveJob.addToRetry(Route route)
Add a route to retry later.
|
Constructor and Description |
---|
CopyTask(List<Route> routes)
Creates a new instance of
CopyJob.CopyTask . |
MoveTask(List<Route> routes)
Creates a new instance of
MoveJob.MoveTask . |
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<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.
|
Modifier and Type | Method and Description |
---|---|
static void |
CopyHandler.copy(Route route,
WriteOptions writeOptions,
FileSystem srcFs,
FileSystem dstFs)
Copies a file from source to destination.
|
static boolean |
ValidateHandler.validate(Route route,
WriteOptions writeOptions,
FileSystem srcFs,
FileSystem dstFs,
boolean isMove)
Validates a file from source to destination.
|
Copyright © 2023. All Rights Reserved.