ストリームデータ処理基盤 uCosminexus Stream Data Platform - Application Framework アプリケーション開発ガイド
ここでは,「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のデータを連結して,ストリームタプルを生成する操作が定義されています。
All Rights Reserved. Copyright (C) 2010, 2014, Hitachi, Ltd.