Spring Batch에서의 파티셔닝(Partitioning)

import org.springframework.batch.core.partition.support.Partitioner;
import org.springframework.batch.item.ExecutionContext;
import java.util.HashMap;
import java.util.Map;

public class RangePartitioner implements Partitioner {

    @Override
    public Map<String, ExecutionContext> partition(int gridSize) {
        Map<String, ExecutionContext> partitions = new HashMap<>();
        int min = 1; // 데이터베이스 ID의 최소값
        int max = 5; // 데이터베이스 ID의 최대값
        int targetSize = (max - min) / gridSize + 1; // 각 Partition의 범위 크기

        int start = min;
        int end = start + targetSize - 1;

        for (int i = 0; i < gridSize; i++) {
            ExecutionContext context = new ExecutionContext();
            context.putInt("minId", start); // 시작 ID
            context.putInt("maxId", end); // 종료 ID
            partitions.put("partition" + i, context);

            start += targetSize;
            end += targetSize;
        }

        return partitions;
    }
}