SQL の変更と互換性への影響 - Realtime Compute for Apache Flink

このトピックでは、デプロイメントの SQL ステートメントでさまざまな変更を実行した場合に、デプロイメントと状態データ間の互換性がどのように影響を受けるかについて説明します。

重要

変更後のデプロイメントと状態データ間の互換性を確認するには、Realtime Compute for Apache Flink の開発コンソールの [デプロイメント] ページの [ジョブの開始] パネルで、状態の互換性チェック結果を表示できます。

シナリオ	説明	参照
クエリの変更	デプロイメントの SQL ステートメントでエイリアスを変更した後に、デプロイメントと状態データ間の互換性がどのように影響を受けるかについて説明します。エイリアスを変更しても、デプロイメントと状態データ間の互換性は影響を受けません。	エイリアス
	デプロイメントの SQL ステートメントで GROUP BY と共に使用される集計関数を変更した後に、デプロイメントと状態データ間の互換性がどのように影響を受けるかについて説明します。	グループ集計
	デプロイメントの SQL ステートメントで OVER と共に使用される集計関数を変更した後に、デプロイメントと状態データ間の互換性がどのように影響を受けるかについて説明します。	Over 集計
	デプロイメントの SQL ステートメントで GROUP BY と共に使用されるウィンドウ集計関数を変更した後に、デプロイメントと状態データ間の互換性がどのように影響を受けるかについて説明します。	グループウィンドウ集計
	デプロイメントの SQL ステートメントでウィンドウテーブル値関数 (TVF) を変更した後に、デプロイメントと状態データ間の互換性がどのように影響を受けるかについて説明します。	ウィンドウ TVF
	デプロイメントの SQL ステートメントで重複除外を変更した後に、デプロイメントと状態データ間の互換性がどのように影響を受けるかについて説明します。	重複除外
	デプロイメントの SQL ステートメントで TopN 関数を変更した後に、デプロイメントと状態データ間の互換性がどのように影響を受けるかについて説明します。	Top-N
	デプロイメントの SQL ステートメントでウィンドウベースの TopN 関数を変更した後に、デプロイメントと状態データ間の互換性がどのように影響を受けるかについて説明します。	ウィンドウ Top-N
	デプロイメントの SQL ステートメントで、通常結合、インターバル結合、時間的結合、またはルックアップ結合を変更した後に、デプロイメントと状態データ間の互換性がどのように影響を受けるかについて説明します。	結合
	デプロイメントの SQL ステートメントでパターン認識を変更した後に、デプロイメントと状態データ間の互換性がどのように影響を受けるかについて説明します。	パターン認識
	デプロイメントの SQL ステートメントで WHERE 句を変更した後に、デプロイメントと状態データ間の互換性がどのように影響を受けるかについて説明します。	Where
	デプロイメントの SQL ステートメントで UNION ALL を変更した後に、デプロイメントと状態データ間の互換性がどのように影響を受けるかについて説明します。	Union All
	デプロイメントの SQL ステートメントで時間的ソートを変更した後に、デプロイメントと状態データ間の互換性がどのように影響を受けるかについて説明します。	時間的ソート
	デプロイメントの SQL ステートメントで LIMIT 句を変更した後に、デプロイメントと状態データ間の互換性がどのように影響を受けるかについて説明します。	LIMIT
ソースコネクタの変更	デプロイメントの SQL ステートメントでソースコネクタを変更した後に、デプロイメントと状態データ間の互換性がどのように影響を受けるかについて説明します。	ソーステーブルの変更
シンクコネクタの変更	デプロイメントの SQL ステートメントでシンクコネクタを変更した後に、デプロイメントと状態データ間の互換性がどのように影響を受けるかについて説明します。	シンクコネクタの変更
その他の制限	デプロイメントのクエリ、ソースコネクタ、およびシンクコネクタを除き、デプロイメントの SQL ステートメントを変更する場合に適用される制限について説明します。	その他の制限

次の DDL ステートメントを使用して作成されたテーブルは、前述のシナリオのサンプル SQL ステートメントのソーステーブルとして使用されます。

CREATE TEMPORARY TABLE MyTable (
  a int,
  b bigint,
  c varchar,
  d int,
  ts timestamp(3),
  proctime as proctime(),
  watermark for ts AS ts - interval '1' second
) WITH (
...);