Package | Description |
---|---|
alluxio.client.file.cache | |
alluxio.client.file.cache.store | |
alluxio.master.job | |
alluxio.master.job.plan | |
alluxio.master.job.workflow |
Modifier and Type | Method and Description |
---|---|
void |
TimeBoundPageStore.put(PageId pageId,
byte[] page) |
void |
PageStore.put(PageId pageId,
byte[] page)
Writes a new page from a source channel to the store.
|
Modifier and Type | Method and Description |
---|---|
void |
LocalPageStore.put(PageId pageId,
byte[] page) |
Modifier and Type | Method and Description |
---|---|
long |
JobMaster.run(JobConfig jobConfig)
Runs a job with the given configuration.
|
void |
JobMaster.run(JobConfig jobConfig,
long jobId)
Runs a job with the given configuration and job id.
|
List<JobCommand> |
JobMaster.workerHeartbeat(JobWorkerHealth jobWorkerHealth,
List<TaskInfo> taskInfoList)
Updates the tasks' status when a worker periodically heartbeats with the master, and sends the
commands for the worker to execute.
|
Modifier and Type | Method and Description |
---|---|
void |
PlanTracker.run(PlanConfig jobConfig,
CommandManager manager,
JobServerContext ctx,
List<WorkerInfo> workers,
long jobId)
Adds a job with the given
JobConfig to the job tracker. |
Modifier and Type | Method and Description |
---|---|
void |
WorkflowTracker.run(WorkflowConfig workflowConfig,
long jobId)
Runs a workflow with the given configuration and job id.
|
Copyright © 2023. All Rights Reserved.