配置批处理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>

 

相关文章:

  • 2021-11-24
  • 2022-12-23
  • 2022-01-21
  • 2021-11-15
  • 2022-12-23
  • 2021-09-06
  • 2022-12-23
  • 2022-01-22
猜你喜欢
  • 2022-12-23
  • 2021-08-10
  • 2021-04-18
  • 2021-11-29
  • 2021-11-22
  • 2021-06-03
  • 2022-02-11
相关资源
相似解决方案