Realtime Compute for Apache Flink:Window Top-N

完全な互換性：ウィンドウ属性フィールドを追加または削除します。

-- 元の SQL ステートメント:
select a, b, c, window_start from (
  select *,
      row_number() over (partition by b, window_start, window_end order by c) as rk
  from (
    select a,
      sum(b) as b,
      max(c) as c,
        window_start,
        window_end
    from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
      group by a, window_start, window_end)
  ) where rk < 3;


-- 完全な互換性：クエリ結果に window_end フィールドを追加します。
select a, b, c, window_start, window_end from (
  select *,
      row_number() over (partition by b, window_start, window_end order by c) as rk
  from (
    select a,
      sum(b) as b,
      max(c) as c,
        window_start,
        window_end
    from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
      group by a, window_start, window_end)
  ) where rk < 3;

完全な互換性：ランキング位置を指定するフィールドをクエリ結果に含めるか除外します。

-- 元の SQL ステートメント:
select a, b, c, window_start from (
  select *,
      row_number() over (partition by b, window_start, window_end order by c) as rk
  from (
    select a,
      sum(b) as b,
      max(c) as c,
        window_start,
        window_end
    from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
      group by a, window_start, window_end)
  ) where rk < 3;


-- 完全な互換性：クエリ結果に rk フィールドを含めます。
select a, b, c, window_start, rk from (
  select *,
      row_number() over (partition by b, window_start, window_end order by c) as rk
  from (
    select a,
      sum(b) as b,
      max(c) as c,
        window_start,
        window_end
    from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
      group by a, window_start, window_end)
  ) where rk < 3;

ウィンドウタイプ、ウィンドウサイズ、時間属性などのウィンドウ関連の属性を変更します。

変更例については、完全な非互換性を引き起こす変更をご参照ください。

group by 句のフィールドを追加、削除、または変更するか、これらのフィールドの計算ロジックを変更します。

変更例については、完全な非互換性を引き起こす変更をご参照ください。

集計フィールドを追加、削除、または変更するか、TOP-N クエリの入力を変更します。

-- 元の SQL ステートメント:
select a, b, c, window_start from (
  select *,
      row_number() over (partition by b, window_start, window_end order by c) as rk
  from (
    select a,
      sum(b) as b,
      max(c) as c,
        window_start,
        window_end
    from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
      group by a, window_start, window_end)
  ) where rk < 3;

-- 非互換：集計フィールドである min(d) as d を追加します。
-- この変更により、TOP-N クエリの入力が変更されます。
select a, b, c, d, window_start from (
  select *,
      row_number() over (partition by b, window_start, window_end order by c) as rk
  from (
    select a,
      sum(b) as b,
      max(c) as c,
      min(d) as d,
        window_start,
        window_end
    from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
      group by a, window_start, window_end)
  ) where rk < 3;

パーティションキーを追加、削除、または変更するか、パーティションキーに含まれるフィールドの計算ロジックを変更します。

変更例については、互換性のない変更をご参照ください。

order by 句に指定されたフィールドまたは順序を変更します。

変更例については、互換性のない変更をご参照ください。

N の値を変更します。Top-N クエリでは、N は返す上位ランク結果の数を指定します。

変更例については、互換性のない変更をご参照ください。