Notice
Recent Posts
Recent Comments
Link
| 일 | 월 | 화 | 수 | 목 | 금 | 토 |
|---|---|---|---|---|---|---|
| 1 | 2 | 3 | 4 | 5 | 6 | |
| 7 | 8 | 9 | 10 | 11 | 12 | 13 |
| 14 | 15 | 16 | 17 | 18 | 19 | 20 |
| 21 | 22 | 23 | 24 | 25 | 26 | 27 |
| 28 | 29 | 30 | 31 |
Tags
- confluent
- play framework
- Slick
- 카프카
- avo
- scala 2.10
- 한빛미디어
- Kafka
- kafkastreams
- kafkastream
- Logstash
- kafka streams
- spring-kafka
- spring-cloud-stream
- schema registry
- Elk
- aws
- Elasticsearch
- spring-batch
- gradle
- RabbitMQ
- statestore
- 플레이 프레임워크
- scala
- springboot
- enablekafkastreams
- coursera
- kafka interactive query
- reactive
- Spring
Archives
- Today
- Total
b
JobParametersIncrementer의 사용. 본문
Job Parameter를 자동으로 Increment 하기 위해서 사용.
(Job의 구현체를 구분하는 방법은 Job + Job Parameter이기 때문에, Parameter없이는 같은 job을 계속 실행하면 안된다)
@Component
public class SimpleJobParametersIncrementer implements JobParametersIncrementer {
static final SimpleDateFormat format = new SimpleDateFormat("yyyyMMdd-hhmmss");
public JobParameters getNext(JobParameters parameters) {
String id = format.format(new Date());
return new JobParametersBuilder().addString("run.id", id).toJobParameters();
}
}
요약
1. JobParametersIncrementer 구현
2. JobExplorerFactoryBean bean 설정
3. job에 increment로 1번 설정
4. 실행은 xmlfile jobanme [-next] 를 추가
참고
http://numberformat.wordpress.com/2010/02/07/multiple-batch-runs-with-spring-batch/
참고2 [BATCH_JOB_PARAMS] 테이블
JOB_INSTANCE_ID TYPE_CD KEY_NAME STRING_VAL DATE_VAL LONG_VAL DOUBLE_VAL
3 STRING run.id 20120825-124631 1970-01-01 09:00:00 0 0
4 STRING run.id 20120825-125909 1970-01-01 09:00:00 0 0
참고3. 기본적으로 제공하는 crementer는
org.springframework.batch.core.launch.support.RunIdIncrementer 가 있고 key를 프로퍼티로 받는다.
'spring framework > spring-batch' 카테고리의 다른 글
| JAXP DOM4J, JDOM2의 성능 비교 (0) | 2013.11.13 |
|---|---|
| Spring Batch Admin (0) | 2013.01.11 |
| JobLauncher, SimpleJobLauncher (0) | 2012.08.28 |
Comments