Realtime Compute for Apache Flink:Window TVF

非重複統計メトリックを追加、削除、および変更します。統計メトリックは、集計関数を使用して計算されます。

• デプロイメントの SQL ステートメントに統計メトリックの集計関数を追加すると、デプロイメントは状態データと部分的に互換性を持つようになります。追加された統計メトリックの値は、デプロイメントの開始時にインクリメントされます。

• デプロイメントの SQL ステートメントから統計メトリックを削除すると、デプロイメントは状態データと完全な互換性を維持します。削除された統計メトリックの状態データは破棄されます。

• デプロイメントの SQL ステートメントに統計メトリックを追加し、ステートメントから統計メトリックを削除すると、デプロイメントは状態データと部分的に互換性を持つようになります。追加された統計メトリックの値は、デプロイメントの開始時にインクリメントされます。削除された統計メトリックの状態データは破棄されます。

• デプロイメントの SQL ステートメントで統計メトリックを変更すると、元の統計メトリックが削除され、新しい統計メトリックが追加されます。デプロイメントは状態データと部分的に互換性を持つようになります。追加された統計メトリックの値は、デプロイメントの開始時にインクリメントされます。削除された統計メトリックの状態データは破棄されます。

-- Original SQL statement: 
select a, sum(b), max(c)
from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
group by a, window_start, window_end;

-- 統計メトリック count(c) を追加します。この変更後、デプロイメントは状態データと部分的に互換性を持つようになります。
-- sum(b) と max(c) の計算結果は影響を受けません。 count(c) の値は、デプロイメントの開始時に 0 からインクリメントされます。
select a, sum(b), max(c), count(c)
from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
group by a, window_start, window_end;

-- 統計メトリック sum(b) を削除します。この変更後、デプロイメントは状態データと完全な互換性を維持します。
-- max(c) の計算結果は影響を受けません。
select a, max(c)
from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
group by a, window_start, window_end;

-- 統計メトリック max(c) を min(c) に変更します。この変更後、デプロイメントは状態データと部分的に互換性を持つようになります。
-- sum(b) の計算結果は影響を受けません。 max(c) は削除されたと見なされ、その状態データは破棄されます。
-- min(c) は新しいメトリックと見なされ、その値はデプロイメントの開始時に計算されます。
select a, sum(b), min(c)
from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
group by a, window_start, window_end;

非重複統計メトリックの位置を変更します。この変更後、デプロイメントは状態データと完全な互換性を維持します。

-- Original SQL statement: 
select a, sum(b), max(c)
from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
group by a, window_start, window_end;

-- 統計メトリック sum(b) と max(c) の位置を変更します。この変更後、デプロイメントは状態データと完全な互換性を維持します。
-- 統計メトリック sum(b) と max(c) の計算結果は影響を受けません。
select a, max(c), sum(b)
from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
group by a, window_start, window_end;

非重複統計メトリックのフィールドの計算ロジックが変更された場合、統計メトリックは変更されたと見なされます。この変更後、デプロイメントは状態データと部分的に互換性を持つようになります。

-- Original SQL statement: 
select a, sum(b), max(c)
from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
group by a, window_start, window_end;

-- 統計メトリック max(c) を max(substring(c,1, 5)) に変更します。この変更後、デプロイメントは状態データと部分的に互換性を持つようになります。
-- sum(b) の計算結果は影響を受けません。 max(c) は削除されたと見なされ、その状態データは破棄されます。
-- max(substring(c, 1, 5)) は新しい統計メトリックと見なされます。 max(substring(c, 1, 5)) の値は、デプロイメントの開始時にインクリメントされます。
create temporary view MyView select a, b, substring(c, 1, 5) as c, ts from MyTable;
select a, sum(b), max(c)
from table (tumble(table MyView, descriptor(ts), interval '1' minute))
group by a, window_start, window_end;

ウィンドウ属性フィールドを追加または削除します。この変更後、デプロイメントは状態データと完全な互換性を維持します。

-- Original SQL statement: 
select a,
  sum(b),
  max(c),
  window_start
from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
  group by a, window_start, window_end;

-- ウィンドウ終了属性を追加します。この変更後、デプロイメントは状態データと完全な互換性を維持します。
select a,
  sum(b),
  max(c),
  window_start,
  window_end
from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
  group by a, window_start, window_end;

-- ウィンドウ開始属性を削除します。この変更後、デプロイメントは状態データと完全な互換性を維持します。
select a,
  sum(b),
  max(c)
from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
  group by a, window_start, window_end;

ウィンドウタイプ、ウィンドウサイズ、時間関連属性などのウィンドウ関連属性を変更すると、デプロイメントは状態データと互換性がなくなります。

-- Original SQL statement: 
select a,
  sum(b),
  max(c),
  window_start
from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
  group by a, window_start, window_end;

-- ウィンドウタイプを TUMBLE から HOP に変更します。この変更後、デプロイメントは状態データと互換性がなくなります。
select a,
  sum(b),
  max(c),
  hop_start(ts, interval '1' minute, interval '2' minute) as window_start
from MyTable
  group by a, hop(ts, interval '1' minute, interval '2' minute);

-- ウィンドウサイズを「1」分から「2」分に変更します。この変更後、デプロイメントは状態データと互換性がなくなります。
select a,
  sum(b),
  max(c),
  tumble_start(ts, interval '2' minute) as window_start
from MyTable
  group by a, tumble(ts, interval '2' minute);

-- 時間関連属性を ts から proctime に変更します。この変更後、デプロイメントは状態データと互換性がなくなります。
select a,
  sum(b),
  max(c),
  tumble_start(ts, interval '1' minute) as window_start
from MyTable
  group by a, tumble(proctime, interval '1' minute);

デプロイメントの SQL ステートメントで、グループキーを追加、削除、または変更するか、グループキーとして使用されるフィールドの計算ロジックを変更すると、デプロイメントは状態データと互換性がなくなります。

-- Original SQL statement: 
select a,
  sum(b),
  max(c),
  tumble_start(ts, interval '1' minute) as window_start
from MyTable
  group by a, tumble(ts, interval '1' minute);

-- グループキー d を追加します。この変更後、デプロイメントは状態データと互換性がなくなります。
select a,
  sum(b),
  max(c),
  tumble_start(ts, interval '1' minute) as window_start
from MyTable
  group by a, d, tumble(ts, interval '1' minute);

-- その他の例については、「GROUP BY で使用される集計関数」のグループキーの変更例を参照してください。

デプロイメントの SQL ステートメントで、重複除外統計メトリックを追加、削除、または変更するか、重複除外統計メトリックに関連するフィールドの計算ロジックを変更すると、デプロイメントは状態データと互換性がなくなります。重複除外統計メトリックは、重複除外集計関数を使用して計算されます。

-- Original SQL statement: 
select a,
  sum(b),
  count(distinct b),
  max(c),
  count(distinct c),
  tumble_start(ts, interval '1' minute) as window_start
from MyTable
  group by a, tumble(ts, interval '1' minute);

-- 重複除外統計メトリック count(distinct b) を追加します。この変更後、デプロイメントは状態データと互換性がなくなります。
select a,
  sum(b),
  max(c),
  count(distinct c),
  tumble_start(ts, interval '1' minute) as window_start
from MyTable
  group by a, tumble(ts, interval '1' minute);

-- その他の例については、「GROUP BY で使用される集計関数」の重複除外統計メトリックの変更例を参照してください。

デプロイメントの SQL ステートメントからすべての統計メトリックを削除すると、デプロイメントは状態データと互換性がなくなります。すべての統計メトリックの状態データは破棄され、状態データは再利用されません。

-- Original SQL statement: 
select a,
  sum(b),
  count(distinct b),
  max(c),
  count(distinct c),
  tumble_start(ts, interval '1' minute) as window_start
from MyTable
  group by a, tumble(ts, interval '1' minute);

-- sum(b) と max(c) を含むすべての統計メトリックを削除します。この変更後、デプロイメントは状態データと互換性がなくなります。
select a,
  tumble_start(ts, interval '1' minute) as window_start
from MyTable
  group by a, tumble(ts, interval '1' minute);