ストリームデータ処理基盤 uCosminexus Stream Data Platform - Application Framework アプリケーション開発ガイド

[目次][索引][前へ][次へ]

9.3.2 クエリグループの定義内容(インプロセス連携カスタムアダプター)

ここでは,「9.3.1 インプロセス連携カスタムアダプターのサンプルプログラムの実行手順」の手順6.で登録したインプロセス連携クエリグループ用プロパティファイル(Inprocess_QueryGroupTest)の内容について説明します。

このクエリグループでは,送信先ストリーム名としてdata0を定義して,受信元ストリーム名として,ポーリング受信用にfilter1を定義しています。

定義内容を次に示します。なお,大文字小文字の表記はサンプルと異なります。

 
REGISTER STREAM data0(name VARCHAR(10), num BIGINT);
REGISTER QUERY filter1 ISTREAM(SELECT * FROM data0[ROWS 1] WHERE data0.num <= 24);