Modifier and Type | Method and Description |
---|---|
long |
RetryHandlingJobMasterClient.run(JobConfig jobConfig) |
long |
JobMasterClient.run(JobConfig jobConfig)
Starts a job based on the given configuration.
|
static void |
JobGrpcClientUtils.run(JobConfig config,
int attempts,
AlluxioConfiguration alluxioConf)
Runs the specified job and waits for it to finish.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractVoidJobDefinition<T extends JobConfig,P extends Serializable>
An abstract job definition where the run task method does not return a value.
|
interface |
JobDefinition<T extends JobConfig,P extends Serializable,R extends Serializable>
A job definition.
|
Modifier and Type | Method and Description |
---|---|
<T extends JobConfig> |
JobDefinitionRegistry.getJobDefinition(T jobConfig)
Gets the job definition from the jTob configuration.
|
Modifier and Type | Class and Description |
---|---|
class |
CompositeConfig
A composite job is a list of jobs to be executed either sequentially or concurrently.
|
Modifier and Type | Method and Description |
---|---|
ArrayList<JobConfig> |
CompositeTask.getJobs() |
ArrayList<JobConfig> |
CompositeConfig.getJobs() |
Constructor and Description |
---|
CompositeConfig(ArrayList<JobConfig> jobs,
Boolean sequential) |
CompositeTask(ArrayList<JobConfig> jobs) |
Modifier and Type | Class and Description |
---|---|
class |
LoadConfig
The configuration of loading a file.
|
Modifier and Type | Method and Description |
---|---|
JobConfig |
JobInfo.getJobConfig() |
Constructor and Description |
---|
JobInfo(long id,
JobConfig jobConfig,
java.util.function.Consumer<JobInfo> statusChangeCallback)
Creates a new instance of
JobInfo . |
Modifier and Type | Class and Description |
---|---|
class |
MigrateConfig
Configuration for the migrate job.
|
Modifier and Type | Class and Description |
---|---|
class |
PersistConfig
The configuration of persisting a file.
|
Modifier and Type | Class and Description |
---|---|
class |
EvictConfig
Configuration of a job evicting a block.
|
class |
MoveConfig
Configuration of a job evicting a block.
|
class |
ReplicateConfig
Configuration of a job replicating a block.
|
Modifier and Type | Class and Description |
---|---|
class |
CompactConfig
Configuration for a job to compact files directly under a directory.
|
Modifier and Type | Method and Description |
---|---|
long |
JobTracker.addJob(JobConfig jobConfig,
CommandManager manager,
JobServerContext ctx,
List<WorkerInfo> workers)
Adds a job with the given
JobConfig to the job tracker. |
static JobCoordinator |
JobCoordinator.create(CommandManager commandManager,
JobServerContext jobServerContext,
List<WorkerInfo> workerInfoList,
Long jobId,
JobConfig jobConfig,
java.util.function.Consumer<JobInfo> statusChangeCallback)
Creates a new instance of the
JobCoordinator . |
javax.ws.rs.core.Response |
JobMasterClientRestServiceHandler.run(JobConfig jobConfig)
Runs a job.
|
long |
JobMaster.run(JobConfig jobConfig)
Runs a job with the given configuration.
|
Modifier and Type | Method and Description |
---|---|
void |
CommandManager.submitRunTaskCommand(long jobId,
int taskId,
JobConfig jobConfig,
Object taskArgs,
long workerId)
Submits a run-task command to a specified worker.
|
Modifier and Type | Method and Description |
---|---|
ArrayList<JobConfig> |
TransformPlan.getJobConfigs() |
Modifier and Type | Method and Description |
---|---|
JobConfig |
WriteAction.generateJobConfig(Layout base,
Layout transformed) |
JobConfig |
TransformAction.generateJobConfig(Layout base,
Layout transformed) |
Modifier and Type | Method and Description |
---|---|
void |
TaskExecutorManager.executeTask(long jobId,
int taskId,
JobConfig jobConfig,
Serializable taskArgs,
RunTaskContext context)
Executes the given task.
|
Constructor and Description |
---|
TaskExecutor(long jobId,
int taskId,
JobConfig jobConfig,
Serializable taskArgs,
RunTaskContext context,
TaskExecutorManager taskExecutorManager)
Creates a new instance of
TaskExecutor . |
Copyright © 2023. All Rights Reserved.