Package | Description |
---|---|
alluxio.job.plan.batch | |
alluxio.master.job.metrics |
Modifier and Type | Method and Description |
---|---|
Class<BatchedJobConfig> |
BatchedJobDefinition.getJobConfigClass() |
Modifier and Type | Method and Description |
---|---|
SerializableVoid |
BatchedJobDefinition.runTask(BatchedJobConfig config,
BatchedJobDefinition.BatchedJobTask task,
RunTaskContext context) |
Set<Pair<WorkerInfo,BatchedJobDefinition.BatchedJobTask>> |
BatchedJobDefinition.selectExecutors(BatchedJobConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
static void |
DistributedCmdMetrics.batchIncrementForCancelStatus(BatchedJobConfig config)
Increment for Cancel status for batch job.
|
static void |
DistributedCmdMetrics.batchIncrementForCompleteStatusWithRetry(BatchedJobConfig config,
FileSystem fileSystem,
RetryPolicy retryPolicy)
Increment for batch config for complete status.
|
static void |
DistributedCmdMetrics.batchIncrementForFailStatus(BatchedJobConfig config)
Increment for Fail status for batch job.
|
Copyright © 2023. All Rights Reserved.