特許

J-GLOBAL ID：200903024225709400

ストリームデータのランキングクエリ処理方法およびランキングクエリ処理機構を有するストリームデータ処理システム

発明者： 西澤 格 ,  今木 常之 ,  樫山 俊彦
出願人/特許権者： 株式会社日立製作所
代理人 (2件)： 井上 学 ,  戸田 裕二
公報種別：公開公報
出願番号（国際出願番号）：特願2008-174086
公開番号（公開出願番号）：特開2009-134689
出願日： 2008年07月03日
公開日（公表日）： 2009年06月18日
要約：

【課題】 (1)ウィンドウへのストリームデータの挿入に加えて、データの消滅の際にも整合性を保つためのランキング計算機構を実現する。(2)ストリームデータ処理システムの汎用性を確保するため、アプリケーションにランキング計算結果を渡すための汎用インタフェース、およびそのインタフェースに従った出力機構を実現する。【解決手段】 (1)ウィンドウへのストリームデータの挿入時、削除時に生成されるストリームタプルの符号を利用して順位情報を管理する機構を提供する。(2)ランキング計算結果の差分情報のみを生成する機構、要求に応じて順位情報を付加する機構、さらに差分情報からランキング全体情報を生成する出力するインタフェース、ランキング計算結果の全体を生成する機構、およびこれらの機構を利用するためのインタフェースを提供する。【選択図】 図1

請求項（抜粋）：

継続的に到来する、タイムスタンプが付与された複数のストリームタプルで構成されるストリームデータを受け付け、予め登録されたクエリにより前記ストリームデータにクエリ処理を継続実行するストリームデータのランキングクエリ処理方法であって、 前記クエリにより指定するウィンドウ指定に従い、各ストリームタプルの到着に対応して、該ストリームタプルのウィンドウ中の生存期間、もしくはそれに加えて過去に到着したストリームタプルのウィンドウ中の生存期間の終了を決定し、 前記クエリにより指定するランキング処理に従い、あるストリームタプルの生存期間が開始するタイミング、及びあるストリームタプルの生存期間が終了するタイミング毎に、ストリームタプル間の順序付け対象項目に関するランキングを算出してそのランキング情報を更新し、 前記順序付け対象項目のランキングが前記クエリで指定する出力指定範囲に含まれるストリームタプルの集合を出力するとともに、該出力指定範囲を越えて生存期間内にあるストリームタプルの更新されたランキング情報を保存することを特徴とするストリームデータのランキングクエリ処理方法。

IPC (2件)：

G06F 17/30 ,  G06F 12/00

FI (3件)：

G06F17/30 350C ,  G06F12/00 513D ,  G06F17/30 415

Fターム (6件)：

5B075KK02 ,  5B075ND02 ,  5B075QS13 ,  5B075UU40 ,  5B082BA09 ,  5B082GA08

引用特許：

出願人引用 (4件)

• 米国特許5495600号
  
• 米国特許7251648号
  
• 米国公開特許US2006/0259457号
  
• ストリームデータ処理システムのクエリ処理方法
  公報種別：公開公報   出願番号：特願2005-163440   出願人：株式会社日立製作所

審査官引用 (1件)

• データベース管理システムにおける集合述部および検索
  公報種別：公開公報   出願番号：特願2001-034814   出願人：インターナショナル・ビジネス・マシーンズ・コーポレーション

引用文献：

審査官引用 (2件)

• 連続的問合せを用いたテキストストリームに対する類似検索
• 音声センサのストリームデータ処理による会議の可視化方法