ItemProcessor

• 데이터를 가공하거나 필터링하는 역할을 함

  → Writer부분에서도 충분히 구현 가능

• Reader, Writer와는 별도의 단계로 분리되어 있기 때문에 비즈니스 코드가 섞이는 것을 방지함

• Reader에서 넘겨준 데이터 개별건을 가공/처리 해줌

• ChunkSize단위로 묶은 데이터를 한번에 처리하는 ItemWriter와는 대조됨

  

  출처: 기억보다 기록을

사용법

// I => ItemReader에서 받을 데이터 타입
// O => ItemWriter에 보낼 데이터 타입
public interface ItemProcessopr<I, O> {
	O process (I item) throw Exception;
}

• 구현해야할 메소드는 process 하나
• 람다식을 사용하여 구현 가능 → 주로 람다식을 사용함

[Example]

@Bean(BEAN_PREFIX + "processor")
@StepScope
public ItemProcessor<ReadType, WriteType> processor() {
    return item -> {
        item.convert();
        return item;
    };
}

참고 자료

9. Spring Batch 가이드 - ItemProcessor