ストリームデータ処理基盤 uCosminexus Stream Data Platform - Application Framework 解説
条件を満たすデータの抽出処理の実行例を次の二つのクエリで説明します。
「気温が0度以下のデータを出力する」という,一つの条件を満たすデータを出力するクエリについて説明します。このクエリを実行した場合の,入力データと出力データを次の図に示します。
図2-15 一つの条件を満たすデータを出力するクエリを実行した場合の入力データと出力データ
REGISTER STREAM temperature_stream (observation_time TIME, id INTEGER, temperature INTEGER); REGISTER QUERY below_zero_filter ISTREAM ( SELECT observation_time, id, temperature FROM temperature_stream[ROWS 1] WHERE temperature <= 0);
「気温が-10度以上,かつ0度以下のデータを出力する」という,二つの条件を満たすデータを出力するクエリについて説明します。このクエリを実行した場合の,入力データと出力データを次の図に示します。
図2-16 二つの条件を満たすデータを出力するクエリを実行した場合の入力データと出力データ
REGISTER STREAM temperature_stream (observation_time TIME, id INTEGER, temperature INTEGER); REGISTER QUERY temperature_range_filter ISTREAM ( SELECT observation_time, id, temperature FROM temperature_stream[ROWS 1] WHERE -10 <= temperature AND temperature <= 0);
All Rights Reserved. Copyright (C) 2010, 2014, Hitachi, Ltd.