Package | Description |
---|---|
alluxio.master.job | |
alluxio.master.scheduler | |
alluxio.scheduler.job |
Modifier and Type | Class and Description |
---|---|
class |
AbstractJob<T extends Task<?>>
Abstract class for job.
|
Modifier and Type | Class and Description |
---|---|
class |
CopyJob.CopyTask
Loads blocks in a UFS through an Alluxio worker.
|
class |
DoraLoadJob.DoraLoadTask
Dora load task.
|
class |
LoadJob.LoadTask
Loads blocks in a UFS through an Alluxio worker.
|
class |
MoveJob.MoveTask
Moves blocks in a UFS through an Alluxio worker.
|
Modifier and Type | Method and Description |
---|---|
int |
CopyJob.CopyTask.compareTo(Task o) |
void |
LoadJob.onTaskSubmitFailure(Task<?> task) |
void |
AbstractJob.onTaskSubmitFailure(Task<?> task) |
Modifier and Type | Method and Description |
---|---|
Map<Scheduler.WorkerInfoIdentity,Scheduler.BoundedPriorityBlockingQueue<Task>> |
Scheduler.WorkerInfoHub.getWorkerToTaskQ() |
Modifier and Type | Method and Description |
---|---|
boolean |
Scheduler.WorkerInfoHub.enqueueTaskForWorker(WorkerInfo workerInfo,
Task task)
Enqueue task for worker.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Job<T extends Task<?>>
interface for job that can be scheduled by Alluxio scheduler.
|
Modifier and Type | Method and Description |
---|---|
int |
Task.compareTo(Task o) |
void |
Job.onTaskSubmitFailure(Task<?> task)
Define how to process task that gets rejected when scheduler tried to kick off.
|
Copyright © 2023. All Rights Reserved.