"複数のアプリケーションサーバ、及びバッチサーバを備えるバッチ処理システムであって、前記アプリケーションサーバそれぞれは、クライアント端末からのアクセスを受け付けてオンライン処理を実行し、該オンライン処理において前記クライアント端末からの入力操作を受け付けるオンラインアプリケーション部と、前記オンライン処理で得られたデータを入力データとしてキューに格納する入力データ処理部と、前記キューに格納された前記入力データを順次取得し、該取得した入力データごとに、バッチ処理として構成されたジョブステップのうち自アプリケーションサーバで先行処理可能な第1ジョブステップの処理を実行し、該実行して得られた先行処理データを先行処理データファイルに記録する先行処理部と、を含み、前記バッチサーバは、前記複数のアプリケーションサーバの各先行処理データファイルを収集してマージするマージ処理部と、前記マージされた先行処理データファイルに基づいて、前記先行処理データを順次読み込み、前記バッチ処理として構成されたジョブステップのうち前記第1ジョブステップを除いた第2ジョブステップの処理を実行するバッチ処理部と、を含むバッチ処理システム。前記クライアント端末からの入力操作は、データの作成、更新、及び削除のいずれかの入力操作であり、前記入力データ処理部は、前記入力データ、及び該入力データに対応する前記入力操作の種類をキューに格納する、請求項1に記載のバッチ処理システム。前記先行処理データファイルは、前記入力データの作成処理を記録する作成ファイルと、前記入力データの更新処理を記録する更新ファイルと、前記入力データの削除処理を記録する削除ファイルと、前記作成ファイル、前記更新ファイル及び前記削除ファイルのいずれかのファイルが記録された場合に該記録内容を記録するインデックスファイルとで構成され、前記マージ処理部は、前記複数のアプリケーションサーバの各先行処理データファイルを収集し、該各先行処理データファイルに含まれる各インデックスファイルの記録内容をマージし、前記バッチ処理部は、前記マージされたインデックスファイルの記録内容に基づいて、前記先行処理データを順次読み込み、前記第2ジョブステップの処理を実行する、請求項2に記載のバッチ処理システム。前記バッチサーバにアクセスし、前記バッチ処理として構成されたジョブステップを解析する解析部、該解析した結果、前記アプリケーションサーバで先行処理可能な第1ジョブステップを抽出する抽出部、及び該抽出された前記第1ジョブステップの処理を前記アプリケーションサーバに配置する配置部を含むジョブステップ分配装置を更に備える、請求項1~請求項3のいずれか1項に記載のバッチ処理システム。前記ジョブステップ分配装置は、前記複数のアプリケーションサーバにアクセスし、前記第1ジョブステップの処理対象となる入力データを扱うオンラインアプリケーションを特定するオンラインアプリケーション特定部を更に含む、請求項4に記載のバッチ処理システム。前記複数のアプリケーションサーバにより出力される前記先行処理データを格納する共有メモリを更に備え、前記マージ処理部は、前記複数のアプリケーションサーバの各先行処理データを前記共有メモリから収集してマージ処理する、請求項1~請求項5のいずれか1項に記載のバッチ処理システム。複数のアプリケーションサーバ、及びバッチサーバを備えるシステムのバッチ処理方法であって、前記アプリケーションサーバが、クライアント端末からのアクセスを受け付けてオンライン処理を実行し、該オンライン処理において前記クライアント端末からの入力操作を受け付ける段階と、前記アプリケーションサーバが、前記オンライン処理で得られたデータを入力データとしてキューに格納する段階と、前記アプリケーションサーバが、前記キューに格納された前記入力データを順次取得し、該取得した入力データごとに、バッチ処理として構成されたジョブステップのうち自アプリケーションサーバで先行処理可能な第1ジョブステップの処理を実行し、該実行して得られた先行処理データを先行処理データファイルに記録する段階と、前記バッチサーバが、前記複数のアプリケーションサーバの各先行処理データファイルを収集してマージする段階と、前記バッチサーバが、前記マージ処理された先行処理データファイルに基づいて、前記先行処理データを順次読み込み、前記バッチ処理として構成されたジョブステップのうち前記第1ジョブステップを除いた第2ジョブステップの処理を実行する段階と、を含むバッチ処理方法。しかしながら、従来の上述したバッチ処理方法では、種々の問題点が存在する。例えば、バッチ処理の開始時刻を早めることで、終了予定時刻までにバッチ処理を完了する方法では、バッチ処理の開始時刻の直前までオンライン処理が実行される場合などのバッチ処理の開始時刻を早くすることができないケースでは、バッチ処理を終了予定時刻までに終了させることはできない。また、バッチ処理対象データを分割して並列実行する方法では、バッチ処理を並列に実行するためのマシンリソースを確保する必要があるため、バッチサーバのマシン増設等のコストがかかってしまう。さらに、バッチ処理対象データの増加を予測し、システム導入段階で、バッチ処理で実施すべき処理をオンライン処理自体に組み込んで実装するように設計する場合、既存のバッチ処理等の定義の変更にかかる開発コストが増大するとともに、予測したとおりにバッチ処理対象データが増加しなかったとき、そのバッチ処理等の定義の変更の作りこみが無駄になってしまい、また、システムの運用開始後に新たなバッチ処理を適用する場合に、オンライン処理自体の修正も必要になってしまう。そこで、本発明は、かかる事情に鑑みてなされたものであり、バッチサーバの増設やバッチ処理の定義を変更せずに、バッチサーバにおけるバッチ処理の実行時間を短縮することができる新しいバッチ処理システム等を提供することを目的とする。本発明にかかるバッチ処理システムは、複数のアプリケーションサーバ、及びバッチサーバを備えるバッチ処理システムであって、アプリケーションサーバそれぞれは、クライアント端末からのアクセスを受け付けてオンライン処理を実行し、該オンライン処理において前記クライアント端末からの入力操作を受け付けるオンラインアプリケーション部と、オンライン処理で得られたデータを入力データとしてキューに格納する入力データ処理部と、キューに格納された入力データを順次取得し、該取得した入力データごとに、バッチ処理として構成されたジョブステップのうち自アプリケーションサーバで先行処理可能な第1ジョブステップの処理を実行し、該実行して得られた先行処理データを先行処理データファイルに記録する先行処理部と、を含み、バッチサーバは、複数のアプリケーションサーバの各先行処理データファイルを収集してマージするマージ処理部と、該マージされた先行処理データファイルに基づいて、先行処理データを順次読み込み、バッチ処理として構成されたジョブステップのうち第1ジョブステップを除いた第2ジョブステップの処理を実行するバッチ処理部と、を含む。本発明にかかるバッチ処理方法は、複数のアプリケーションサーバ、及びバッチサーバを備えるシステムのバッチ処理方法であって、アプリケーションサーバが、クライアント端末からのアクセスを受け付けて、オンライン処理を実行し、該オンライン処理において前記クライアント端末からの入力操作を受け付ける段階と、アプリケーションサーバが、オンライン処理で得られたデータを入力データとしてキューに格納する段階と、アプリケーションサーバが、キューに格納された入力データを順次取得し、該取得した入力データごとに、バッチ処理として構成されたジョブステップのうち自アプリケーションサーバで先行処理可能な第1ジョブステップの処理を実行し、該実行して得られた先行処理データを先行処理データファイルに記録する段階と、バッチサーバが、複数のアプリケーションサーバの各先行処理データファイルを収集してマージする段階と、バッチサーバが、マージ処理された先行処理データファイルに基づいて、先行処理データを順次読み込み、バッチ処理として構成されたジョブステップのうち第1ジョブステップを除いた第2ジョブステップの処理を実行する段階と、を含む。以上のように構成された本発明のバッチ処理システム等によれば、バッチ処理を構成する一部のジョブステップの処理をアプリケーションサーバに先行処理させることで、バッチサーバにおけるバッチ処理の実行時間を短縮することができる。また、システムの運用開始後であっても、大容量データに対応したバッチ処理システムとして容易に構成変更することができる。さらに、バッチサーバの追加や増強をせずに、また、既存のバッチ処理の定義を変更することなく、アプリケーションサーバをスケールアウトするだけでシステムにおけるバッチ処理の処理能力を拡張することができる。以下、本発明を実施するための好適な各実施形態を、図面を参照しながら説明する。<第1実施形態>図1は、本発明の第1実施形態のシステム1の概略構成の一例を示す図である。なお、本実施形態のシステム1は、オンライン処理中に発生した入力データに対して所定の処理を行い、該処理の結果を出力データとして所定のデータベースに記録処理するといった一連の処理ジョブステップを含むバッチ処理を実行する場合を例にとって説明する。システム1は、図1に示すとおり、複数のクライアント端末10と、複数のアプリケーションサーバ20a~20zと、バッチサーバ30と、時刻サーバ40と、バッチ処理用の入力データ処理対象データを格納する入力データベース50と、バッチ処理後の出力データを格納する出力データベース60と、を含んで構成され、これらは必要に応じて通信ネットワークを介して相互に通信可能に接続されている。なお、クライアント端末10、複数のアプリケーションサーバ20a~20z、バッチサーバ30、及び時刻サーバ40は、ハードウェアとして、図2に示すように、例えば、CPU、CPUにバス結合されたROM、RAM、記憶部、入力部、表示部、および入出力インタフェースなど、通常のコンピュータ装置と同様のハードウェアを備える。また、これらの各サーバや端末は、物理的には、専用化したシステム、あるいは汎用の情報処理装置のいずれであってもよい。たとえば、一般的な構成の情報処理装置において、本発明のバッチ処理方法における各処理を規定したソフトウェアを起動することにより、アプリケーションサーバやバッチサーバを実現することもできる。クライアント端末10は、アプリケーションサーバ20a~20zにアクセスし、アプリケーションのオンライン処理中に発生する入力データの作成、更新、又は削除を操作する端末である。なお、クライアント端末10の構成および機能は、原則として、従来のアプリケーションサーバにアクセスし、オンラインアプリケーションオンライン処理で実行するアプリケーションを利用可能なクライアント端末と同様の構成および機能とすることができる。また、クライアント端末10の数は、本実施形態では特に制限されず、少なくとも1つ以上あればよい。アプリケーションサーバ20a~20zは、それぞれオンライン処理を実行するサーバである。なお、アプリケーションサーバ20a~20zは、それぞれの構成を共通とすることができるので、以下では、アプリケーションサーバ20aを例にとってその構成を説明する。アプリケーションサーバ20aは、オンラインアプリケーション部21、入力データ処理部22、キュー部23、及び先行処理部24を含んで構成される。オンラインアプリケーション部21は、ネットワークを通じてクライアント端末10からのアクセスを受け付けて、オンライン処理を実行する。また、オンラインアプリケーション部21は、オンライン処理中にクライアント端末10からの入力操作を受け付ける。クライアント端末からの入力操作は、データの作成、更新、及び削除のいずれかの入力操作であり得る。すなわち、オンラインアプリケーション部21は、オンライン処理においてクライアント端末10から入力されたデータの作成処理、更新処理、及び削除処理のいずれかの処理をハンドリングすることができる。入力データ処理部入力データハンドラ22は、オンライン処理で得られたデータを入力データとしてキュー部23に格納する。また、入力データ処理部22は、入力データとともに、該入力データに対応する前記入力操作の種類もキュー部23に格納することができる。なお、この入力データは、バッチ処理を行うバッチ処理対象データである。キュー部キュー23は、入力データバッチ処理対象データごとに、入力データ及び該入力データの処理内容例えば、作成、更新、又は削除を順次格納する。なお、キュー部23は、非同期キューであることが望ましい。先行処理部24は、図3に示すように、データ取得部キューデータ取得部241、データ処理部データ加工処理部242、及びファイルデータ記録部ファイルデータ書込み部243で構成され、データ取得部241がキュー部23に格納された入力データを順次取得し、データ処理部242が、該取得した入力データごとに、バッチサーバ30においてバッチ処理として構成されたジョブステップのうち自アプリケーションサーバ20aで先行処理可能な第1ジョブステップの処理を実行し、ファイルデータ記録部243が、該実行した結果先行処理データを先行処理データファイルに記録する。なお、第1ジョブステップは、例えば、バッチ処理として定義されるジョブステップのうちトランザクショナル処理を行わないジョブステップである。ここで、先行処理データファイルは、例えば、図4に示すように、入力データの作成処理を記録する作成ファイルINSERTファイルと、入力データの更新処理を記録する更新ファイルUPDATEファイルと、入力データの削除処理を記録する削除ファイルDELETEファイルと、作成ファイル、更新ファイル及び削除ファイルのいずれかのファイルが記録された場合に該記録内容を記録するインデックスファイルINDEXファイルとを含んで構成することができる。このように先行処理データファイルが構成される場合、先行処理部24は、先行処理データファイルに記録する際に、オンライン処理中に発生した入力データの処理内容作成処理、更新処理、又は削除処理に応じて、先行処理データの記録先を振り分けて記録し、且つ、先行処理データファイルが更新されたことをインデックスファイルに記録する。なお、先行処理データファイルは、上述のものに限られず、アプリケーションサーバにおいてオンライン処理中に発生した入力データやその処理内容に応じて、適宜変更することができる。バッチサーバ30は、マージ処理部31と、バッチ処理部32とを含んで構成される。マージ処理部31は、複数のアプリケーションサーバ20a~20zの各先行処理データファイルを収集してマージする。バッチ処理部32は、マージ処理された先行処理データファイルマージファイルに基づいて、バッチ処理として構成されたジョブステップのうち第1ジョブステップを除いた第2ジョブステップの処理を実行する。バッチ処理部32は、第2ジョブステップの処理された結果出力データを出力データベース60に記憶する。なお、第2ジョブステップは、例えば、第1ジョブステップとは異なり、バッチ処理として定義されるジョブステップのうちトランザクショナル処理を行うジョブステップである。ここで、先行処理データファイルが、例えば、図4に示すような先行処理データファイルで構成される場合、マージ処理部31は、複数のアプリケーションサーバ20a~20zの各先行処理データファイルを収集し、該各先行処理データファイルに含まれる各インデックスファイルの記録内容をマージする。そして、バッチ処理部32は、マージされたインデックスファイルインデックスマージファイルの記録内容に従って、該当する先行処理データを作成ファイル、更新ファイル及び削除ファイルのいずれかのファイルを順次読み込み、第2ジョブステップの処理を実行する。時刻サーバ40は、各アプリケーションサーバ20a~20zの時刻を同期するためのサーバである。なお、時刻サーバ40の構成および機能は、原則として、従来の複数のアプリケーションサーバの時刻を同期する一般的な時刻サーバと同様の構成および機能とすることができる。入力データベース50は、各アプリケーションサーバ20a~20zでオンライン処理中に発生したバッチ処理用の入力データバッチ処理対象データを格納するデータベースである。なお、入力データベース50は、省略することもできる。出力データベース60は、バッチサーバ30においてバッチ処理されて出力された出力データを記憶するデータベースである。以下、図5及び図6に示すフローチャートを参照して、本実施形態のバッチ処理方法を説明する。なお、以下の説明では、各アプリケーションサーバ20a,20bにおいてオンライン処理で実行するアプリケーションとして、例えば、図7に示すように、支店ごとの勤務管理テーブルにクライアント端末から入力データ社員ID、就業開始時刻、就業終了時刻を作成更新削除することができるものを例にとって説明する。また、上述の第1ジョブステップの処理として、入力データ社員ID、就業開始時刻、及び就業終了時刻を受け取り、これらから作業時間の計算処理を行い、該作業時間の計算結果等を先行処理データ社員ID、日付、作業時間として出力するものとする。さらに、上述の第2ジョブステップの処理として、各アプリケーションサーバ20a,20bで生成された先行処理データに記載されているデータを出力データとして本社勤務管理テーブル出力データベースに記録するものとする。まず、図5を参照して、アプリケーションサーバ20aにおける動作処理を例にとって説明するが、アプリケーションサーバ20bもアプリケーションサーバ20aと同様に動作処理することができる。なお、図5のフローチャートで示される各処理は、処理内容に矛盾を生じない範囲で任意に順番を変更して又は並列に実行することができる。アプリケーションサーバ20aは、クライアント端末10からのアクセスを受け付けて、オンライン処理を実行するステップS100。次いで、アプリケーションサーバ20aは、オンライン処理においてクライアント端末10から入力された入力データの各処理作成処理、更新処理、及び削除処理の少なくとも1つの処理をハンドリングするステップS101。例えば、図7に示すように、アプリケーションサーバ20aはA支店の勤務管理テーブルを管理し、アプリケーションサーバ20bはB支店の勤務管理テーブルを管理するものとすると、アプリケーションサーバ20aは、A支店の勤務管理テーブルに対して、クライアント端末10から入力された入力データ社員ID00001、開始時刻2010年2月1日8:30、及び終了時刻2010年2月1日17:15の作成処理をハンドリングする。入力データの処理の完了を検知するとステップS102:Yes、アプリケーションサーバ20aは、該入力データをキュー部23に格納するステップS103。一方、入力データの処理の完了を検知しない場合ステップS102:No、アプリケーションサーバ20aは、検知するまで待機する。なお、検知せずに、本処理フローを終了してもよい。次いで、アプリケーションサーバ20aは、キュー部23に格納された入力データを順次取得するステップS104。例えば、図7に示すように、アプリケーションサーバ20aでは、社員ID00001等の情報、社員ID00003等の入力データを順次取得する。アプリケーションサーバ20aは、バッチサーバ30においてバッチ処理として構成されたジョブステップのうち自アプリケーションサーバで先行処理可能な第1ジョブステップの処理を実行するステップS105。例えば、図7に示すように、アプリケーションサーバ20aでは、社員ID00001の就業開始時刻8:30及び就業終了時刻17:15の情報から、作業時間の計算処理を行い、計算処理された結果7.75hは先行処理データとして扱われる。アプリケーションサーバ20aは、入力データの処理内容が作成処理であればステップS106:Yes、該処理された入力データ先行処理データを先行処理データファイルの作成ファイルに記録するステップS107。例えば、図8に示すように、図7に示す社員ID00001に関する先行処理データは作成ファイルに記録される。アプリケーションサーバ20aは、入力データの処理内容が更新処理であればステップS108:Yes、先行処理データを先行処理データファイルの更新ファイルに記録するステップS109。アプリケーションサーバ20aは、入力データの処理内容が、削除処理であればステップS110:Yes、先行処理データを先行処理データファイルの削除ファイルに記録するステップS111。アプリケーションサーバ20aは、ステップS107、ステップS109、ステップS111の各処理後、先行処理データファイルのインデックスファイルに記録内容が更新されたことを記録するステップS112。例えば、図8に示すように、インデックスファイルにおいて、社員IDおよび日付情報をレコード特定キーとして、対象ファイル名、更新時刻が記録される。次に、図6を参照して、バッチサーバ30における動作処理を説明する。なお、図6のフローチャートで示される各処理は、処理内容に矛盾を生じない範囲で任意に順番を変更して又は並列に実行することができる。バッチサーバ30は、複数のアプリケーションサーバ20a,20bの各先行処理データファイルa,bを収集し、該各先行処理データファイルa,bに含まれる各インデックスファイルの記録内容をマージするステップS200。例えば、図8に示すように、各インデックスファイルの記録内容をマージして、マージファイル先行処理データINDEXマージファイルを作成する。バッチサーバ30は、マージ処理された先行処理データファイルマージファイルに基づいて、バッチ処理として構成されたジョブステップのうち第1ジョブステップを除いた第2ジョブステップの処理を実行するステップS201。すなわち、マージファイルから一つ一つのレコード特定キーに対応する対象ファイル例えば、作成ファイル等を読み込み、図8に示すように、該対象ファイルの内容を出力データとして本社勤務管理データベース出力データベースに記録する。以上のように、本実施形態によれば、バッチ処理を構成する一部のジョブステップの処理をアプリケーションサーバに先行処理させることで、バッチサーバにおけるバッチ処理の実行時間を短縮することができる。ここで、具体的に、本実施形態のシステムと従来のシステムとの相違について図9及び図10を用いて説明する。従来のオンライン処理とバッチ処理を行う連携システムは、図9に示すように構成されており、その動作フローは、例えば、図10aに示すように、オンライン処理として、アプリケーションサーバでオンライン処理Aされた各入力データA1~A4を一旦バッチ入力データベースオンライン入出力データベースに格納する。次いで、バッチサーバにおいて、バッチ処理としてバッチ入力データベースから各入力データA1~A4を取り出して第1ジョブステップJ1の処理処理S1を実行し、該第1ジョブステップの処理をしたデータA1~A4を中間処理データファイルに書き出し、第1ジョブステップの処理の完了後、第2ジョブステップJ2の処理処理S2を実行し、中間処理データファイルに記載されている内容を出力データとして出力する。一方、本実施形態のシステムは、図10bに示すように、アプリケーションサーバでオンライン処理Aされた各入力データA1~A4を入力として第1ジョブステップJ1の処理を先行処理し、該処理したデータA1~A4を先行処理データファイルに記録し、該先行処理データファイルをマージ処理した後、第2ジョブステップJ2の処理処理S2を実行している。よって、本実施形態のシステムによれば、バッチサーバでのバッチ処理にかかる実行時間を短縮することができる。特に、バッチ処理すべきバッチ処理対象データが増大しても、バッチサーバ自体にかかる実行時間は、先行処理データファイルをマージするのに要する時間と、先行処理データを出力データとして出力するのに要する時間とで、バッチサーバにおける実行時間を略同一にすることができ、バッチ処理が予め決められた時刻で開始され、且つ、予め決められた時刻までに終了する必要がある場合に有効である。また、従来のシステムとして上述した特許文献1のシステムの処理方法は、アプリケーションサーバにてバッチ対象データが確定していない状態であっても、バッチ処理対象データが発生した時点で該データをロット化してバッチ処理を先行して処理する場合、バッチ処理対象データの変更があるたびに逐一中間結果のデータをバッチ処理によって更新するものであったが、このような方法では、オンライン処理で扱うデータが増加することで、バッチ対象データの更新が並列処理され、該並列処理が頻繁に発生すると、そのたびに中間結果を更新しなければならず、バッチサーバ上での先行処理が追いつかなくなってしまう。しかし、本実施形態のシステムによれば、バッチ処理対象データを1件ずつ扱うようなジョブステップに限定し、該ジョブステップの先行処理を複数のアプリケーションサーバ上で分散並列実行することで、1件の先行処理が他の先行処理に影響を与えることなく処理可能にし、オンライン処理を実行するアプリケーションサーバ側のスケールアウトによって得られるマシンリソースを活用しながら、小規模なバッチサーバであっても大容量データに対応可能にすることができる。よって、本実施形態によれば、システムの運用開始後であっても、大容量データに対応したバッチ処理システムとして容易に構成変更することができる。さらに、バッチサーバの追加や増強を変更せずに、また、既存のバッチ処理の定義を変更することなく、アプリケーションサーバをスケールアウトするだけでシステムにおけるバッチ処理の処理能力を拡張することができる。さらに、本実施形態では、バッチサーバにおいて上記各インデックスファイルを用いてマージし、マージされたインデックスファイルの記録内容に基づいて、前記先行処理データを順次読み込みことで、マージにかかる時間を短縮できる。<第2実施形態>図11は、第2実施形態のシステム2の概略構成の一例を示す図である。第2実施形態のシステム2は、第1実施形態のシステム1のシステム構成に加え、更に、各アプリケーションサーバ20a~20zに対して上記第1ジョブステップの処理を分配するジョブステップ分配装置70を備えることを特徴とする。なお、以下では、第2実施形態のシステム2において、上記第1実施形態のシステム1と同様にできる構成及び機能については、その説明を省略する。ジョブステップ分配装置70は、図11に示すように、ジョブステップ解析部71、ジョブステップ抽出部72、アプリケーション特定部73、ジョブステップ配置部74、及びジョブステップ組み換え部75を含んで構成される。ジョブステップ解析部解析部71は、バッチサーバ30にアクセスし、バッチ処理として構成されたジョブステップを解析する。具体的には、ジョブステップ解析部71は、バッチ処理として定義されている上述した第1ジョブステップ及び第2ジョブステップのうち、トランザクション処理を行わない第1ジョブステップの有無を解析する。なお、ジョブステップ解析部71は、例えば、バッチ処理として実行を完了すべき時刻が設定されており、バッチ処理の開始時刻等によってバッチジョブが指定した時間までに終わらないと判断した場合に、上記解析を行うようにすることもできる。ジョブステップ抽出部抽出部72は、上記解析した結果、アプリケーションサーバ20a~20zで先行処理可能な第1ジョブステップがある場合、該第1ジョブステップを抽出する。具体的には、第1ジョブステップの処理内容の情報プログラムを抽出する。アプリケーション特定部オンラインアプリケーション解析部73は、アプリケーションサーバ20a~20zにアクセスし、第1ジョブステップの処理対象となる入力データを扱うアプリケーションオンラインアプリケーションを特定する。ジョブステップ配置部配置部74は、上記ジョブステップ抽出部72で抽出された第1ジョブステップの処理を上記アプリケーション特定部73で特定されたオンラインアプリケーションを実行するアプリケーションサーバ20a~20zに配置する。具体的には、特定されたオンラインアプリケーションの入力データ操作部分へ第1ジョブステップの処理を非同期で実行するよう、ハンドラを組み込む。ジョブステップ組み換え部75は、ジョブステップ解析部71によるジョブステップ解析結果に基づいてジョブステップの処理を組み替え、マージ処理部31においてマージするジョブステップの処理内容を決定する。以上のように構成される第2実施形態のシステム2によれば、バッチ処理として定義されたジョブステップの処理内容に応じて、自動的にアプリケーションサーバ20a~20zにその処理を振り分けることができる。また、アプリケーション特定部73を有することで、第1ジョブステップの処理対象となる入力データを扱うオンラインアプリケーションが実行されるアプリケーションサーバのみに上記ジョブステップを配置することができるため、効率性を高めたシステムを提供することができる。<第3実施形態>図12は、第3実施形態のシステム3の概略構成の一例を示す図である。本実施形態のシステム3は、各アプリケーションサーバ20a~20zにおいてオンライン処理として、例えば、図13に示すように、発注処理用のオンライン処理から入力される発注テーブルの表から、商品マスタテーブルに記録されている発注先のデータを特定し、バッチ処理として、該特定したデータ発注先、発注元、商品コード、個数を集計するジョブステップの処理、及び該集計結果等を基に発注先ごとに発注明細を送付するジョブステップの処理を含むものを例にとって説明する。なお、第3実施形態のシステム3は、第1実施形態のシステム1の入力データ処理部入力データハンドラ22の代わりに、入力データ処理部差分データハンドラ22を備えることを特徴とする。なお、以下では、第3実施形態のシステム3において、上記第1実施形態のシステム1と同様にできる構成及び機能については、その説明を省略する。入力データ処理部差分データハンドラ22は、上記の集計処理、すなわち、N個のデータからM個のデータを作成するようなジョブステップの処理を行う場合、オンライン処理からの入力データの操作によって発生するデータの差分を取得して差分データを生成し、該差分データをキュー部23に格納する。先行処理部24は、差分データに基づいて集計が反映された先行処理データを先行処理データファイルに記録する。本実施形態の先行処理データファイルは、例えば、図14に示すように、集計ファイルと、該集計ファイルが記録された場合に該記録内容を記録するインデックスファイルINDEXファイルとで構成することができる。マージ処理部先行処理データマージ処理部32は、複数のアプリケーションサーバ20a~20zの各先行処理データファイルを収集して、再度集計処理を行って先行処理データをマージする。以上のように構成される第3実施形態のシステム3によれば、先行処理データが部分的に集計したデータとなるため、バッチサーバにて一度に全ての集計を行う従来のバッチ処理方法よりも、短い時間で集計を行うことができる。すなわち、バッチサーバにおけるバッチ処理の実行時間を短縮することができる。<第4実施形態>図15は、第4実施形態のシステム4の概略構成の一例を示す図である。第4実施形態のシステム4は、第1実施形態のシステム1のシステム構成に加え、更に、先行処理データの書き込み先として、更に、共有メモリ80を備えることを特徴とする。なお、以下では、第4実施形態のシステム4において、上記第1実施形態のシステム1と同様にできる構成及び機能については、その説明を省略する。共有メモリ分散共有メモリ80は、複数のアプリケーションサーバ20a~20zにより出力される各先行処理データを格納するメモリである。マージ処理部31は、複数のアプリケーションサーバ20a~20zの各先行処理データを共有メモリ80から収集してマージ処理する。以上のように構成される第4実施形態のシステム4によれば、共有メモリ80を備えることで、マージ処理時のオーバーヘッドを軽減することができる。<変形例>以上のように本発明の好適な実施形態について説明したが、本発明は、以上の実施形態に限定されるべきものではなく、特許請求の範囲に表現された思想および範囲を逸脱することなく、種々の変形、追加、および省略が当業者によって可能である。たとえば、上記実施形態において、アプリケーションサーバ20及びバッチサーバ30には、用途に応じた各部が備えられているが、これらに備えられている各部は、そのいくつかを一纏めにして構成されていてもよいし、一つの部をさらに複数の部に分割して構成されていてもよい。さらに、上記実施形態では、アプリケーションサーバ20において、それぞれの処理機能を有する各部が備えられている構成を説明したが、本発明はこれに限られず、各部がアプリケーションサーバ20と通信可能に接続されたネットワーク上に又は他の装置に備えて構成することもできる。上記の実施形態の一部または全部は、以下の付記のようにも記載されうるが、以下には限られない。付記1複数のアプリケーションサーバ、及びバッチサーバを備えるバッチ処理システムであって、前記アプリケーションサーバそれぞれは、クライアント端末からのアクセスを受け付けてオンライン処理でアプリケーションを実行し、該オンライン処理において前記クライアント端末からの入力操作を受け付けるオンラインアプリケーション部と、前記オンライン処理で得られたデータを入力データとしてキューに格納する入力データ処理部と、前記キューに格納された前記入力データを順次取得し、該取得した入力データごとに、バッチ処理として構成されたジョブステップのうち自アプリケーションサーバで先行処理可能な第1ジョブステップの処理を実行し、該実行して得られた先行処理データを先行処理データファイルに記録する先行処理部と、を含み、前記バッチサーバは、前記複数のアプリケーションサーバの各先行処理データファイルを収集してマージするマージ処理部と、前記マージされた先行処理データファイルに基づいて、前記先行処理データを順次読み込み、前記バッチ処理として構成されたジョブステップのうち前記第1ジョブステップを除いた第2ジョブステップの処理を実行するバッチ処理部と、を含むバッチ処理システム。付記2前記クライアント端末からの入力操作は、データの作成、更新、及び削除のいずれかの入力操作であり、前記入力データ処理部は、前記入力データ、及び該入力データに対応する前記入力操作の種類をキューに格納する、付記1に記載のバッチ処理システム。付記3前記先行処理データファイルは、前記入力データの作成処理を記録する作成ファイルと、前記入力データの更新処理を記録する更新ファイルと、前記入力データの削除処理を記録する削除ファイルと、前記作成ファイル、前記更新ファイル及び前記削除ファイルのいずれかのファイルが記録された場合に該記録内容を記録するインデックスファイルとで構成され、前記マージ処理部は、前記複数のアプリケーションサーバの各先行処理データファイルを収集し、該各先行処理データファイルに含まれる各インデックスファイルの記録内容をマージし、前記バッチ処理部は、前記マージされたインデックスファイルの記録内容に基づいて、前記先行処理データを順次読み込み、前記第2ジョブステップの処理を実行する、付記2に記載のバッチ処理システム。付記4前記バッチサーバにアクセスし、前記バッチ処理として構成されたジョブステップを解析する解析部、該解析した結果、前記アプリケーションサーバで先行処理可能な第1ジョブステップを抽出する抽出部、及び該抽出された前記第1ジョブステップの処理を前記アプリケーションサーバに配置する配置部を含むジョブステップ分配装置を更に備える、付記1~付記3のいずれか1項に記載のバッチ処理システム。付記5前記ジョブステップ分配装置は、前記アプリケーションサーバにアクセスし、前記第1ジョブステップの処理対象となる入力データを扱うアプリケーションを特定するアプリケーション特定部を更に含む、付記4に記載のバッチ処理システム。付記6前記複数のアプリケーションサーバにより出力される前記先行処理データを格納する共有メモリを更に備え、前記マージ処理部は、前記複数のアプリケーションサーバの各先行処理データを前記共有メモリから収集してマージ処理する、付記1~付記5のいずれか1項に記載のバッチ処理システム。付記7複数のアプリケーションサーバ、及びバッチサーバを備えるシステムのバッチ処理方法であって、前記アプリケーションサーバが、クライアント端末からのアクセスを受け付けて、オンライン処理でアプリケーションを実行し、該オンライン処理において前記クライアント端末からの入力操作を受け付ける段階と、前記アプリケーションサーバが、前記オンライン処理で得られたデータを入力データとしてキューに格納する段階と、前記アプリケーションサーバが、前記キューに格納された前記入力データを順次取得し、該取得した入力データごとに、バッチ処理として構成されたジョブステップのうち自アプリケーションサーバで先行処理可能な第1ジョブステップの処理を実行し、該実行して得られた先行処理データを先行処理データファイルに記録する段階と、前記バッチサーバが、前記複数のアプリケーションサーバの各先行処理データファイルを収集してマージする段階と、前記バッチサーバが、前記マージ処理された先行処理データファイルに基づいて、前記先行処理データを順次読み込み、前記バッチ処理として構成されたジョブステップのうち前記第1ジョブステップを除いた第2ジョブステップの処理を実行する段階と、を含むバッチ処理方法。"