Spring BatchのPartitionerで、同じファイル名を持つ処理IDをまとめて1つのWorkerに渡すことは可能です。

同一ファイル名でのグルーピング処理

この要件を実現するには、Partitionerの実装内で、DBから取得したデータをファイル名でグループ化してからWorkerに渡す処理を実装します。

以下に、その考え方と処理の流れを示します。

1. データ取得: DBから処理idとファイル名のペアを取得します。

   [{"処理id": "$a$", "ファイル名": "$A$"},
    {"処理id": "$b$", "ファイル名": "$A$"},
    {"処理id": "$c$", "ファイル名": "$B$"},
    {"処理id": "$d$", "ファイル名": "$C$"}]
   

2. ファイル名によるグルーピング: 取得したデータをファイル名をキーとしてMapなどでグループ化します。

   { "$A$": ["$a$", "$b$"],
     "$B$": ["$c$"],
     "$C$": ["$d$"] }
   

3. Workerへの引き渡し: グループ化された各エントリ（ファイル名とそれに紐づく処理IDリスト）を、それぞれ1つのWorkerに渡すためのExecutionContextを作成します。

   • 例えば、ファイル名をExecutionContextのキーとして設定し、その値として処理IDのリストを渡します。
   • 例:
     • ExecutionContext 1: {"fileKey": "$A$", "processIds": ["$a$", "$b$"]}
     • ExecutionContext 2: {"fileKey": "$B$", "processIds": ["$c$"]}
     • ExecutionContext 3: {"fileKey": "$C$", "processIds": ["$d$"]}

4. Workerでの処理: Worker側では、渡されたExecutionContextからfileKeyとprocessIdsを取得し、それらに基づいて処理を実行します。

実装のポイント

• Partitionerインターフェースの実装: Partitionerインターフェースのpartitionメソッド内で、上記1〜3の処理を行います。
• ExecutionContextの利用: 各Workerに渡したいデータ（この場合はファイル名と処理IDリスト）は、ExecutionContextに格納して返します。
• データ数の変動への対応: Mapなどを使ったグルーピング処理は、データ数が可変であっても問題なく対応できます。

この方法により、同じファイル名を持つ処理IDを効率的にまとめて処理することができます。