Modifier and Type | Method and Description |
---|---|
abstract JobConfig |
JobAttempt.getJobConfig()
Get job config.
|
Modifier and Type | Method and Description |
---|---|
long |
JobMasterClient.run(JobConfig jobConfig)
Starts a plan based on the given configuration.
|
long |
RetryHandlingJobMasterClient.run(JobConfig jobConfig) |
static long |
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 |
AbstractVoidPlanDefinition<T extends JobConfig,P extends Serializable>
An abstract job definition where the run task method does not return a value.
|
interface |
PlanDefinition<T extends JobConfig,P extends Serializable,R extends Serializable>
A job definition.
|
Modifier and Type | Interface and Description |
---|---|
interface |
PlanConfig
A plan configuration.
|
Modifier and Type | Class and Description |
---|---|
class |
BatchedJobConfig
The configuration of loading a file.
|
class |
NoopPlanConfig
Config for a plan that does nothing.
|
Modifier and Type | Method and Description |
---|---|
<T extends JobConfig> |
PlanDefinitionRegistry.getJobDefinition(T jobConfig)
Gets the job definition from the job configuration.
|
Modifier and Type | Method and Description |
---|---|
JobConfig |
BatchedJobDefinition.BatchedJobTask.getJobConfig() |
Constructor and Description |
---|
BatchedJobTask(JobConfig config,
Serializable jobTasks) |
Modifier and Type | Class and Description |
---|---|
class |
LoadConfig
The configuration of loading a file.
|
Modifier and Type | Method and Description |
---|---|
JobConfig |
PlanInfo.getJobConfig() |
Constructor and Description |
---|
PlanInfo(long id,
JobConfig jobConfig,
java.util.function.Consumer<PlanInfo> statusChangeCallback)
Creates a new instance of
PlanInfo . |
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 |
MoveConfig
Configuration of a job moving a block.
|
class |
SetReplicaConfig
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 | Interface and Description |
---|---|
interface |
WorkflowConfig
A workflow configuration.
|
Modifier and Type | Method and Description |
---|---|
Set<JobConfig> |
WorkflowExecution.next()
Given the previous set of jobs were completed successfully,
returns a list of jobs to execute next.
|
protected abstract Set<JobConfig> |
WorkflowExecution.nextJobs()
Given the previous set of jobs were completed successfully,
returns a list of jobs to execute next.
|
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> |
CompositeConfig.getJobs() |
protected Set<JobConfig> |
CompositeExecution.nextJobs() |
Constructor and Description |
---|
CompositeConfig(ArrayList<JobConfig> jobs,
Boolean sequential) |
Modifier and Type | Method and Description |
---|---|
javax.ws.rs.core.Response |
JobMasterClientRestServiceHandler.run(JobConfig jobConfig)
Runs a job.
|
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 |
CommandManager.submitRunTaskCommand(long jobId,
long taskId,
JobConfig jobConfig,
Object taskArgs,
long workerId)
Submits a run-task command to a specified worker.
|
Modifier and Type | Method and Description |
---|---|
static void |
DistributedCmdMetrics.incrementForAllConfigsCancelStatus(JobConfig config)
Increment for both batch and non-batch configs for Cancel status.
|
static void |
DistributedCmdMetrics.incrementForAllConfigsCompleteStatus(JobConfig config,
FileSystem fileSystem,
RetryPolicy retryPolicy)
Increment for both batch and non-batch configs for COMPLETE status.
|
static void |
DistributedCmdMetrics.incrementForAllConfigsFailStatus(JobConfig config)
Increment for both batch and non-batch configs for Fail status.
|
static void |
DistributedCmdMetrics.incrementForCompleteStatusWithRetry(JobConfig config,
FileSystem fileSystem,
RetryPolicy retryPolicy)
Increment for non-batch config for complete status.
|
Modifier and Type | Method and Description |
---|---|
static PlanCoordinator |
PlanCoordinator.create(CommandManager commandManager,
JobServerContext jobServerContext,
List<WorkerInfo> workerInfoList,
Long jobId,
JobConfig jobConfig,
java.util.function.Consumer<PlanInfo> statusChangeCallback)
Creates a new instance of the
PlanCoordinator . |
Modifier and Type | Method and Description |
---|---|
JobConfig |
CmdRunAttempt.getJobConfig()
Get job config.
|
Modifier and Type | Method and Description |
---|---|
void |
CmdRunAttempt.setConfig(JobConfig config)
Set job config.
|
Modifier and Type | Class and Description |
---|---|
class |
StressBenchConfig
Config for the stress test.
|
Modifier and Type | Method and Description |
---|---|
ArrayList<JobConfig> |
TransformPlan.getJobConfigs() |
Modifier and Type | Method and Description |
---|---|
JobConfig |
CompactAction.generateJobConfig(Layout base,
Layout transformed,
boolean deleteSrc) |
JobConfig |
TransformAction.generateJobConfig(Layout base,
Layout transformed,
boolean deleteSrc) |
Copyright © 2023. All Rights Reserved.