| 摘要 |
【課題】分散処理を行うクラスタシステムのスケーラビリティを確保しつつ、ストリーム処理の処理時間を短縮させる。【解決手段】ストリームデータが複数に断片化された断片化データを処理するサーバ１０−０であって、ＫＶＳ（Key Value Store）のＩＤ（Identifier）空間においてストリームデータの時系列に沿い、かつ、隣接して配置されるように、複数の断片化データの各々を複数のサーバの各々に格納するデータ格納部１１３と、マスタとなる断片化データのレプリカを生成するレプリカ生成部１１４と、を備え、データ格納部１１３が、ＩＤ空間において、マスタを格納するサーバに隣接するサーバに、レプリカを格納し、自身のサーバ１０−０に格納されており、時系列的に連続しているマスタおよびレプリカを処理する、ことを特徴とする。【選択図】図２ |
