Realtime Compute でデータビューを作成して、開発プロセスを簡略化できます。

構文

計算ロジックが複雑な場合は、Realtime Compute でデータビューを定義して作成し、開発プロセスを簡略化できます。
注 データビューは計算ロジックの記述を補助するもので、物理的なデータ保存にはつながりません。 
CREATE VIEW viewName[ (columnName[ , columnName]*
) ] AS queryStatement;

例 1

CREATE VIEW LargeOrders (r, t, c, u) AS
SELECT
    rowtime,
    productId,
    c,
    units
FROM
    orders;
INSERT INTO
    rds_output
SELECT
    r,
    t,
    c,
    u
FROM
    LargeOrders;

例 2

  • テストデータ
    a(VARCHAR) b (BIGINT) c (TIMESTAMP)
    test1 1 1506823820000
    test2 1 1506823850000
    test1 1 1506823810000
    test2 1 1506823840000
    test2 1 1506823870000
    test1 1 1506823830000
    test2 1 1506823860000
  • テスト文
    CREATE TABLE datahub_stream (
   a VARCHAR,
   b BIGINT,
   c TIMESTAMP,
   d AS PROCTIME()
) WITH (
  TYPE='datahub',
  ...
);
CREATE TABLE rds_output (
   a VARCHAR,
   b TIMESTAMP, 
   cnt BIGINT,
   PRIMARY KEY(a)
)WITH(
  TYPE = 'rds',
  ...
);
CREATE VIEW rds_view AS
SELECT a, 
   CAST(
      HOP_START(d, INTERVAL '5' SECOND, INTERVAL '30' SECOND) AS TIMESTAMP
   ) AS cc, 
   SUM(b) AS cnt
FROM 
   datahub_stream 
GROUP BY
    HOP(d, INTERVAL '5' SECOND, INTERVAL '30' SECOND),a;
INSERT INTO 
   rds_output
SELECT
   a,
   cc,
   cnt
FROM 
   rds_view
WHERE clause 
   cnt=4
  • テスト結果
    a(VARCHAR) b (TIMESTAMP) cnt (BIGINT)
    test2 2017-11-06 16:54:10 4