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.
|
class |
CopyJob
Copy job that copy a file or a directory from source to destination.
|
class |
DoraLoadJob
Load job that loads a file or a directory into Alluxio.
|
class |
LoadJob
Load job that loads a file or a directory into Alluxio.
|
class |
MoveJob
Move job that move a file or a directory from source to destination.
|
Modifier and Type | Method and Description |
---|---|
Job<?> |
LoadJobFactory.create() |
Job<?> |
CopyJobFactory.create() |
Job<?> |
MoveJobFactory.create() |
Job<?> |
JournalCopyJobFactory.create() |
Job<?> |
JournalLoadJobFactory.create() |
Job<?> |
JournalMoveJobFactory.create() |
Modifier and Type | Field and Description |
---|---|
Map<Job,String> |
Scheduler.SchedulerStats.mExistingJobAndProgresses |
Map<Job,List<String>> |
Scheduler.SchedulerStats.mRunningJobToTasksStat |
Modifier and Type | Method and Description |
---|---|
Set<Job<?>> |
JournaledJobMetaStore.getJobs() |
Map<JobDescription,Job<?>> |
Scheduler.getJobs()
Get jobs.
|
Modifier and Type | Method and Description |
---|---|
boolean |
Scheduler.submitJob(Job<?> job)
Submit a job.
|
void |
JournaledJobMetaStore.updateJob(Job<?> job) |
Modifier and Type | Field and Description |
---|---|
protected Job |
Task.mMyJob |
Modifier and Type | Method and Description |
---|---|
Job<?> |
JobFactory.create() |
Job |
Task.getJob()
Get the job this task belongs to.
|
Modifier and Type | Method and Description |
---|---|
Set<Job<?>> |
JobMetaStore.getJobs() |
Modifier and Type | Method and Description |
---|---|
void |
Task.setJob(Job job)
Set the job.
|
void |
JobMetaStore.updateJob(Job<?> job)
Update existing job in the meta store with the new job.
|
Constructor and Description |
---|
Task(Job job,
int taskId)
constructs Task.
|
Copyright © 2023. All Rights Reserved.