Skip to content

Commit b04cd3f

Browse files
committed
Update docs and samples with the new chunk step implementation
Related to #3950
1 parent 1a58e6b commit b04cd3f

File tree

35 files changed

+156
-61
lines changed

35 files changed

+156
-61
lines changed

spring-batch-docs/modules/ROOT/pages/common-patterns.adoc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -766,7 +766,7 @@ public Job job1(JobRepository jobRepository, Step step1, Step step2) {
766766
@Bean
767767
public Step step1(JobRepository jobRepository, PlatformTransactionManager transactionManager) {
768768
return new StepBuilder("step1", jobRepository)
769-
.<String, String>chunk(10, transactionManager)
769+
.<String, String>chunk(10).transactionManager(transactionManager)
770770
.reader(reader())
771771
.writer(savingWriter())
772772
.listener(promotionListener())

spring-batch-docs/modules/ROOT/pages/processor.adoc

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -101,7 +101,7 @@ public Job ioSampleJob(JobRepository jobRepository, Step step1) {
101101
@Bean
102102
public Step step1(JobRepository jobRepository, PlatformTransactionManager transactionManager) {
103103
return new StepBuilder("step1", jobRepository)
104-
.<Foo, Bar>chunk(2, transactionManager)
104+
.<Foo, Bar>chunk(2).transactionManager(transactionManager)
105105
.reader(fooReader())
106106
.processor(fooProcessor())
107107
.writer(barWriter())
@@ -205,7 +205,7 @@ public Job ioSampleJob(JobRepository jobRepository, Step step1) {
205205
@Bean
206206
public Step step1(JobRepository jobRepository, PlatformTransactionManager transactionManager) {
207207
return new StepBuilder("step1", jobRepository)
208-
.<Foo, Foobar>chunk(2, transactionManager)
208+
.<Foo, Foobar>chunk(2).transactionManager(transactionManager)
209209
.reader(fooReader())
210210
.processor(compositeProcessor())
211211
.writer(foobarWriter())

spring-batch-docs/modules/ROOT/pages/readers-and-writers/delegate-pattern-registering.adoc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ public Job ioSampleJob(JobRepository jobRepository, Step step1) {
3030
@Bean
3131
public Step step1(JobRepository jobRepository, PlatformTransactionManager transactionManager) {
3232
return new StepBuilder("step1", jobRepository)
33-
.<String, String>chunk(2, transactionManager)
33+
.<String, String>chunk(2).transactionManager(transactionManager)
3434
.reader(fooReader())
3535
.processor(fooProcessor())
3636
.writer(compositeItemWriter())

spring-batch-docs/modules/ROOT/pages/scalability.adoc

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ public TaskExecutor taskExecutor() {
5252
@Bean
5353
public Step sampleStep(TaskExecutor taskExecutor, JobRepository jobRepository, PlatformTransactionManager transactionManager) {
5454
return new StepBuilder("sampleStep", jobRepository)
55-
.<String, String>chunk(10, transactionManager)
55+
.<String, String>chunk(10).transactionManager(transactionManager)
5656
.reader(itemReader())
5757
.writer(itemWriter())
5858
.taskExecutor(taskExecutor)
@@ -103,7 +103,7 @@ follows:
103103
@Bean
104104
public Step sampleStep(TaskExecutor taskExecutor, JobRepository jobRepository, PlatformTransactionManager transactionManager) {
105105
return new StepBuilder("sampleStep", jobRepository)
106-
.<String, String>chunk(10, transactionManager)
106+
.<String, String>chunk(10).transactionManager(transactionManager)
107107
.reader(itemReader())
108108
.writer(itemWriter())
109109
.taskExecutor(taskExecutor)

spring-batch-docs/modules/ROOT/pages/step/chunk-oriented-processing/commit-interval.adoc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ public Job sampleJob(JobRepository jobRepository, Step step1) {
2929
@Bean
3030
public Step step1(JobRepository jobRepository, PlatformTransactionManager transactionManager) {
3131
return new StepBuilder("step1", jobRepository)
32-
.<String, String>chunk(10, transactionManager)
32+
.<String, String>chunk(10).transactionManager(transactionManager)
3333
.reader(itemReader())
3434
.writer(itemWriter())
3535
.build();

spring-batch-docs/modules/ROOT/pages/step/chunk-oriented-processing/configuring-skip.adoc

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ The following Java example shows an example of using a skip limit:
2222
@Bean
2323
public Step step1(JobRepository jobRepository, PlatformTransactionManager transactionManager) {
2424
return new StepBuilder("step1", jobRepository)
25-
.<String, String>chunk(10, transactionManager)
25+
.<String, String>chunk(10).transactionManager(transactionManager)
2626
.reader(flatFileItemReader())
2727
.writer(itemWriter())
2828
.faultTolerant()
@@ -83,7 +83,7 @@ The following Java example shows an example excluding a particular exception:
8383
@Bean
8484
public Step step1(JobRepository jobRepository, PlatformTransactionManager transactionManager) {
8585
return new StepBuilder("step1", jobRepository)
86-
.<String, String>chunk(10, transactionManager)
86+
.<String, String>chunk(10).transactionManager(transactionManager)
8787
.reader(flatFileItemReader())
8888
.writer(itemWriter())
8989
.faultTolerant()

spring-batch-docs/modules/ROOT/pages/step/chunk-oriented-processing/configuring.adoc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ public Job sampleJob(JobRepository jobRepository, Step sampleStep) {
3333
public Step sampleStep(JobRepository jobRepository, // <2>
3434
PlatformTransactionManager transactionManager) { // <1>
3535
return new StepBuilder("sampleStep", jobRepository)
36-
.<String, String>chunk(10, transactionManager) // <3>
36+
.<String, String>chunk(10).transactionManager(transactionManager) // <3>
3737
.reader(itemReader())
3838
.writer(itemWriter())
3939
.build();

spring-batch-docs/modules/ROOT/pages/step/chunk-oriented-processing/controlling-rollback.adoc

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ In Java, you can control rollback as follows:
2121
@Bean
2222
public Step step1(JobRepository jobRepository, PlatformTransactionManager transactionManager) {
2323
return new StepBuilder("step1", jobRepository)
24-
.<String, String>chunk(2, transactionManager)
24+
.<String, String>chunk(2).transactionManager(transactionManager)
2525
.reader(itemReader())
2626
.writer(itemWriter())
2727
.faultTolerant()
@@ -75,7 +75,7 @@ The following example shows how to create a reader that does not buffer items in
7575
@Bean
7676
public Step step1(JobRepository jobRepository, PlatformTransactionManager transactionManager) {
7777
return new StepBuilder("step1", jobRepository)
78-
.<String, String>chunk(2, transactionManager)
78+
.<String, String>chunk(2).transactionManager(transactionManager)
7979
.reader(itemReader())
8080
.writer(itemWriter())
8181
.readerIsTransactionalQueue()

spring-batch-docs/modules/ROOT/pages/step/chunk-oriented-processing/intercepting-execution.adoc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ The following example shows a listener applied at the chunk level in Java:
2727
@Bean
2828
public Step step1(JobRepository jobRepository, PlatformTransactionManager transactionManager) {
2929
return new StepBuilder("step1", jobRepository)
30-
.<String, String>chunk(10, transactionManager)
30+
.<String, String>chunk(10).transactionManager(transactionManager)
3131
.reader(reader())
3232
.writer(writer())
3333
.listener(chunkListener())

spring-batch-docs/modules/ROOT/pages/step/chunk-oriented-processing/registering-item-streams.adoc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ The following example shows how to register a `stream` on a `step` in Java:
2525
@Bean
2626
public Step step1(JobRepository jobRepository, PlatformTransactionManager transactionManager) {
2727
return new StepBuilder("step1", jobRepository)
28-
.<String, String>chunk(2, transactionManager)
28+
.<String, String>chunk(2).transactionManager(transactionManager)
2929
.reader(itemReader())
3030
.writer(compositeItemWriter())
3131
.stream(fileItemWriter1())

0 commit comments

Comments
 (0)