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

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

9.2.2 クエリグループの定義内容(RMI連携カスタムアダプター)

ここでは,「9.2.1 RMI連携カスタムアダプターのサンプルプログラムの実行手順」の手順6.で登録したクエリグループ(RMI_QueryGroupTest)の内容について説明します。

このRMI連携クエリグループ用プロパティファイルでは,s1,s2という名称の2種類のストリームと,joinという名称のクエリを定義しています。生成されたストリームタプルは,クエリ名joinをストリーム名とする出力ストリームとして出力されます。

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

 
REGISTER STREAM s1(c1 INT, c2 VARCHAR(20));
REGISTER STREAM s2(c1 INT, c2 VARCHAR(20));
 
REGISTER QUERY join
ISTREAM(SELECT s1.c1 AS ID1, s1.c2 AS VAL1, s2.c2 AS VAL2
FROM s1[ROWS 3], s2[ROWS 2]
WHERE s1.c1 = s2.c1);
 

ストリームs1とs2のデータを連結して,ストリームタプルを生成する操作が定義されています。