パーティショニングにSpringバッチステップを設定しようとしています。良いサンプルは、hereは "id range"についてのパーティションを示していますが、 "データページ"の範囲でどこから始めるべきか分かりません。私のシーケンシャルステップSpringバッチステップPagingAndSortingRepositoryを使用したパーティショニング
、私は:
- リーダー:データ変換
- ライタ:5 :CrudRepository
- chunckを用いRepositoryItemWriter PagingAndSortingRepository
- プロセッサを使用してRepositoryItemReaderを
- リスナー:aステップリスナー
return stepBuilderFactory.get("stepApplicationForm") .<OldApplicationForm, NewApplicationForm>chunk(5) .reader(reader).processor(processor).writer(writer) .listener(listener).build();
、partitionningのために、私は、その後、私は子供のステップでパーティショナを使用するように指示する「親」のステップを持って、パーティを作成するために、リーダーとし、「子」のステップを持っています「ページ区切り」パラメータを認識します。
TaskExecutorについては、私はThreadPoolTaskExecutor
が適合すると思います。
データ "ページ"に基づいてパーティショニングを実装または設定するにはどうすればよいですか?そして、私がチェックしなければならないスレッディング・キャビットは何ですか?
感謝:)
上記のコードを使用すると、スキップメカニズムも使用できます。これは特に、不完全なレコードのためにバッチを失敗させたくない場合に便利です。 –