@Component
public class YarnJobLauncher
extends java.lang.Object
implements org.springframework.context.ApplicationEventPublisherAware
launch
Spring Batch ジョブのユーティリティクラス。デフォルトでは周囲のコンテキスト内のすべてのジョブを実行します。jobName を提供することで特定のジョブを起動するためにも使用できます コンストラクターと説明 |
---|
YarnJobLauncher() |
修飾子と型 | メソッドと説明 |
---|---|
protected void | executeJob(org.springframework.batch.core.Job job, org.springframework.batch.core.JobParameters jobParameters) |
org.springframework.batch.core.explore.JobExplorer | getJobExplorer() |
org.springframework.batch.core.launch.JobLauncher | getJobLauncher() ジョブランチャーを取得します。 |
java.lang.String | getJobName() 有効なジョブ名を取得します。 |
org.springframework.batch.core.configuration.JobRegistry | getJobRegistry() |
java.util.Collection<org.springframework.batch.core.Job> | getJobs() ジョブを得ます。 |
protected void | launchJobFromProperties(java.util.Properties properties) Properties を使用してジョブを起動します。 |
void | run(java.util.Properties properties) ジョブを実行します。 |
void | run(java.lang.String... args) ジョブを実行します。 |
void | setApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher publisher) |
void | setJobExplorer(org.springframework.batch.core.explore.JobExplorer jobExplorer) |
void | setJobLauncher(org.springframework.batch.core.launch.JobLauncher jobLauncher) ジョブランチャーを設定します。 |
void | setJobName(java.lang.String jobName) 有効なジョブ名を設定します。 |
void | setJobParametersConverter(org.springframework.batch.core.converter.JobParametersConverter converter) |
void | setJobRegistry(org.springframework.batch.core.configuration.JobRegistry jobRegistry) |
void | setJobs(java.util.Collection<org.springframework.batch.core.Job> jobs) ジョブを設定します。 |
void | setYarnBatchProperties(YarnBatchProperties yarnBatchProperties) |
public void setApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher publisher)
org.springframework.context.ApplicationEventPublisherAware
の setApplicationEventPublisher
public void run(java.lang.String... args) throws org.springframework.batch.core.JobExecutionException
args
- 引数 org.springframework.batch.core.JobExecutionException
- ジョブ実行例外 public void run(java.util.Properties properties) throws org.springframework.batch.core.JobExecutionException
properties
- ジョブのプロパティ org.springframework.batch.core.JobExecutionException
- ジョブ実行例外 public void setJobName(java.lang.String jobName)
PatternMatchUtils.simpleMatch(String, String)
でサポートされている単純なパターンにすることもでき、カンマで区切ると複数のパターンを一致させることができます。jobName
- 新しい作業名 public java.lang.String getJobName()
setJobName(String)
@Autowired public void setJobLauncher(org.springframework.batch.core.launch.JobLauncher jobLauncher)
jobLauncher
- 新しいジョブランチャー public org.springframework.batch.core.launch.JobLauncher getJobLauncher()
@Autowired(required=false) public void setJobRegistry(org.springframework.batch.core.configuration.JobRegistry jobRegistry)
public org.springframework.batch.core.configuration.JobRegistry getJobRegistry()
@Autowired(required=false) public void setJobParametersConverter(org.springframework.batch.core.converter.JobParametersConverter converter)
@Autowired(required=false) public void setJobExplorer(org.springframework.batch.core.explore.JobExplorer jobExplorer)
public org.springframework.batch.core.explore.JobExplorer getJobExplorer()
@Autowired(required=false) public void setJobs(java.util.Collection<org.springframework.batch.core.Job> jobs)
jobs
- 新しい作業 public java.util.Collection<org.springframework.batch.core.Job> getJobs()
@Autowired(required=false) public void setYarnBatchProperties(YarnBatchProperties yarnBatchProperties)
protected void launchJobFromProperties(java.util.Properties properties) throws org.springframework.batch.core.JobExecutionException
Properties
を使用してジョブを起動します。properties
- プロパティ org.springframework.batch.core.JobExecutionException
- ジョブ実行例外 protected void executeJob(org.springframework.batch.core.Job job, org.springframework.batch.core.JobParameters jobParameters) throws org.springframework.batch.core.JobExecutionException
org.springframework.batch.core.JobExecutionException