java ee wildfly 批处理 job 工作

Posted 2020-10-17 Bigben

配置批处理job，同时启动两个并行任务processData，syncTableTask，执行往后执行第三个任务job：playDurationTask。

xml配置如下：

<job id="statTask" xmlns="http://xmlns.jcp.org/xml/ns/javaee"
    version="1.0">
    <properties>
        <property name="targetDate" value="20001010" />
        <property name="bitcoinFile" value="bitcoins.txt" />
    </properties>
    <split id="split1" next="processDatabase">

        <flow id="flow1">
            <step id="processData">
                <batchlet ref="playProcessLogTask">
                    <properties>
                        <property name="firstItem" value="#{partitionPlan[‘firstItem‘]}" />
                        <property name="numItems" value="#{partitionPlan[‘numItems‘]}" />
                    </properties>
                </batchlet>

                <partition>
                    <mapper ref="playProcessLogMapper" />
                </partition>
            </step>
        </flow>
         
        <flow id="flow2">
            <step id="syncTableTask">
                <batchlet ref="syncTableTask">
                </batchlet>
            </step>
        </flow>
    </split>

    <step id="processDatabase">
        <batchlet ref="playDurationTask">
        </batchlet>
    </step>
</job>