Package | Description |
---|---|
alluxio.client.file.cache | |
alluxio.client.file.cache.store | |
alluxio.client.file.dora | |
alluxio.master.job | |
alluxio.master.job.plan | |
alluxio.master.job.workflow |
Modifier and Type | Method and Description |
---|---|
default void |
PageStore.put(PageId pageId,
byte[] page)
Writes a new page from a source channel to the store.
|
default void |
PageStore.put(PageId pageId,
byte[] page,
boolean isTemporary)
Writes a new page from a source channel to the store.
|
void |
PageStore.put(PageId pageId,
ByteBuffer page,
boolean isTemporary)
Writes a new page from a source channel to the store.
|
default void |
PageStore.putTemporary(PageId pageId,
byte[] page)
Writes a new temporary page from a source channel to the store.
|
Modifier and Type | Method and Description |
---|---|
void |
LocalPageStore.put(PageId pageId,
ByteBuffer page,
boolean isTemporary) |
Modifier and Type | Method and Description |
---|---|
List<BlockWorkerInfo> |
LocalWorkerPolicy.getPreferredWorkers(List<BlockWorkerInfo> blockWorkerInfos,
String fileId,
int count)
Finds a local worker from the available workers, matching by hostname.
|
List<BlockWorkerInfo> |
ConsistentHashPolicy.getPreferredWorkers(List<BlockWorkerInfo> blockWorkerInfos,
String fileId,
int count) |
List<BlockWorkerInfo> |
WorkerLocationPolicy.getPreferredWorkers(List<BlockWorkerInfo> blockWorkerInfos,
String fileId,
int count)
Find a specified number of workers following the logic defined by the policy.
|
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.
|
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.