Konfiguration von Spring Batch Schritte Parallel (Split) mit Anmerkungen

Wo ich immer suchen in Spring Batch Dokumentation für die Ausführung der Schritte in den parallelen, ich sehe nur die Konfiguration über XML, wie unten angegeben.

<split id="split1" next="step4">
<flow>
    <step id="step1" parent="s1" next="step2"/>
    <step id="step2" parent="s2"/>
</flow>
<flow>
    <step id="step3" parent="s3"/>
</flow>

Ich Schreibe eine Anwendung mit Spring Batch, wo ich verwendet, Spring Boot, und alle meine Konfigurationen erfolgen unter Verwendung von Annotationen. Gibt es eine, die ich konfigurieren kann, einen Split Schritt mit Hilfe der Java-Konfiguration? Ich habe in der API Dokumentation der Step-Schnittstelle in Spring Batch, aber es verfügt nicht über eine Standard-implementation für den Split-Schritt. Ist es Weg, kann ich implementieren Sie unter Verwendung der vorhandenen Standard-Implementierungen?

Derzeit implementierte ich meine anderen jobs wie diese :

@Bean
public Step someStep() {
    return stepBuilderFactory.get("someStep")
            .<A, B> chunk(1-).reader(someReader)
            .processor(someProcessor).writer(someWriter).build();
}

@Bean
public Job historicalDataJob() {
    return jobBuilderFactory.get("someJOb")
            .incrementer(new RunIdIncrementer()).flow(someStep()).end()
            .build();
}
InformationsquelleAutor Dhanush Gopinath | 2014-12-23
  1. 11

    Den SimpleJobBuilder bietet Einrichtungen für die Konfiguration von split über java-config. Unten ist ein Beispiel, genommen von der FlowJobBuilderTests (https://github.com/spring-projects/spring-batch/blob/master/spring-batch-core/src/test/java/org/springframework/batch/core/job/builder/FlowJobBuilderTests.java). Natürlich werden Sie wollen, diese zu brechen ein wenig, aber es sollte verdeutlichen die Allgemeine Idee.

    //Create each flow
Flow flow = new FlowBuilder<Flow>("subflow").from(step1).end();

//Create the job
SimpleJobBuilder builder = new JobBuilder("flow").repository(jobRepository).start(step2);

//Create split providing an async task executor so the flows are executed in parallel
builder.split(new SimpleAsyncTaskExecutor()).add(flow).end();

//Build the job and execute it
builder.preventRestart().build().execute(execution);
    • Vielen Dank Michael. Ich check das morgen und update
    • Ja, es funktioniert. Danke. Hoffe, Sie fügen Sie diese an die Spring-Dokumentation
    InformationsquelleAutor Michael Minella
Schreibe einen Kommentar