SpringSpring BatchStepChunk

Spring Batch - ItemProcessor

출처

목차

ItemProcessor

ItemProcessor는 Step 내에서 사용될 데이터를 변환 또는 가공하는 역할을 합니다. ItemReader가 읽어온 데이터를 ItemProcessor가 받아들여 처리하고, 처리한 결과를 ItemWriter에 전달합니다.

ItemProcessor는 일반적으로 데이터 변환, 유효성 검사, 필터링 또는 데이터 가공과 같은 작업을 수행하는 데 사용됩니다. 예를 들어, ItemProcessor를 사용하여 입력 데이터의 길이를 제한하거나, 데이터를 수정하거나, 유효성을 검사하거나, 데이터를 필터링할 수 있습니다.

ItemProcessor는 단일 입력 값을 받아 처리 결과를 반환하는 단순한 함수형 인터페이스인 ItemProcessor<T, S>를 구현합니다. 여기서 T는 입력 유형이고, S는 출력 유형입니다.

ItemProcessor는 스텝 처리 과정에서 중요한 역할을 합니다. 데이터를 변환 또는 가공하여 ItemWriter가 처리할 수 있는 형식으로 변환하므로, 대용량 데이터 세트를 효율적으로 처리하는 데 매우 유용합니다. 또한, ItemProcessor를 사용하여 데이터 유효성 검사 및 데이터 가공 작업을 수행하여 데이터 품질을 유지하고, 필요한 작업을 수행할 수 있습니다.

ItemProcessor 인터페이스

public interface ItemProcessor {

    public Object processItem(Object item) throws Exception;
}

ItemProccesor 구현체 종류

ClassifierCompoisteItemProcessor

ClassifierCompositeItemProcessor는 Spring Batch의 ItemProcessor 인터페이스를 구현한 클래스로, 다중 프로세싱 전략을 적용할 수 있도록 설계된 컴포지트(Composite) 패턴의 구현체입니다.

ClassifierCompositeItemProcessor는 Classifier라는 인터페이스를 구현하고 있습니다. Classifier는 하나의 입력 값을 기반으로 여러 개의 출력 값을 생성할 수 있는 기능을 제공합니다. ClassifierCompositeItemProcessor는 이 기능을 활용하여 하나의 입력 항목을 여러 개의 ItemProcessor에 전달하여 처리할 수 있습니다.

CmopositeItemProcessor

CustomItemProcessor

Share