<job id="basic_Sample" xmlns="http://www.springframework.org/schema/batch">

          <split id="split1" task-executor="taskExecutor" next="addr">

                      <flow>

                           <step id="wbras_bsid_1-1" next="dong_1-2"/>

                           <step id="dong_1-2"/>

                </flow>

                      <flow>

                           <step id="wbras_bsid_2-1" next="dong_2-2"/>                                                  <step id="dong_2-2"/>

                </flow>

     </split>

     <step  id=”addr”>

     </step>

</job>

위의 예제같이 흐름이 그려진다면  wbras_bsid_1-1과 wbras_Bsid_2-1이 같이실행되며 스레드 구조로 다음 스텝들을 서로의 플로어(flow) 안에서 실행이 된다.
각각의 플로어가 종료되면 split1에서 설정한 next=”addr” 로 인해 step addr로 이동하며 실행하게 된다.
기타사항으로는 플로어중 exception이 있는 플로어는 실행도중 종료되며 다른 플로어는 계속 실행을 하게된다. 하지만 split안의 플로어중 exception이 일어났을경우는 다음 스텝으로 가지 못하고 fail이 된다. (skip , retry 설정으로 극복

Multi-record

n  Read된 값들의 종류에 따라 record되는 값이 달라진다.

if (item instanceof Trade) {

        return this.tradeLineAggregator.aggregate((Trade) item);

}

else if (item instanceof CustomerCredit) {

        return this.customerLineAggregator.aggregate((CustomerCredit) item);

}

else {

        throw new RuntimeException();

}                 

라인 어그리에이터의 소스 부분의 모습이다. 받아온 item의 타입에 따라 사용되는 어그리에이터가 달라지는 것이다. 
 

Multi-line

public Trade read() throws Exception {

Trade t = null;

           for (FieldSet line = null; (line = this.delegate.read()) != null;) {

                      String prefix = line.readString(0);

                     if (prefix.equals("BEGIN")) {

                                t = new Trade(); // Record must start with 'BEGIN'

                     }

                     else if (prefix.equals("INFO")) {

                                Assert.notNull(t, "No 'BEGIN' was found.");

                                t.setIsin(line.readString(1));

                                t.setCustomer(line.readString(2));

                     }

                     else if (prefix.equals("AMNT")) {

                                Assert.notNull(t, "No 'BEGIN' was found.");

                                t.setQuantity(line.readInt(1));

                                t.setPrice(line.readBigDecimal(2));

                     }

                     else if (prefix.equals("END")) {

                                return t; // Record must end with 'END'

                     }

           }

           Assert.isNull(t, "No 'END' was found.");

           return null;

}

ItemReader 부분이다. Read 해서 FieldSet으로 나눠서 나오는 첫번째 값에따라 반환값이 달라진다.

begin일땐 새로 생성하고 info 일땐 값을 입력하고 amnt일땐 다른 값을 입력한다. 이들은 다 리턴을 널값으로 보내준다. 오직 end 값일때만 만들어진 Trade를 리턴해준다. 

요약하면 여러라인 받아놓고 반환 라인 타이밍을 조절하는 것이 Multi-line이다.

Multi-file

<bean id="itemReaderForTest" parent="itemReaderParent">

     <property name="resources" value="classpath:data/ /input/delimited*.csv" />

</bean>

이런 식의 빈설정으로 resources는 여러 개의 리소스 값들을 받아온다. 이를 setresources할 때 값은

private Resource[] resources;
이런식으로 배열로 들어가게 된다. 이후 안에 있는값들은 JAVA로 만든 핸들러를 통해 사용된다.