Modifikasi SQL dan dampak pada kompatibilitas - Realtime Compute for Apache Flink

Topik ini menjelaskan bagaimana kompatibilitas antara deployment dan data state terpengaruh ketika Anda melakukan berbagai modifikasi dalam pernyataan SQL untuk deployment tersebut.

Penting

Untuk memeriksa kompatibilitas antara deployment dan data state setelah modifikasi, Anda dapat melihat hasil pemeriksaan kompatibilitas state di panel Start Job halaman Deployments di konsol pengembangan Realtime Compute for Apache Flink.

Skenario	Deskripsi	Referensi
Memodifikasi query	Menjelaskan bagaimana kompatibilitas antara deployment dan data state terpengaruh setelah Anda mengubah alias dalam pernyataan SQL untuk deployment. Jika Anda mengubah alias, kompatibilitas antara deployment dan data state tidak terpengaruh.	Alias
	Menjelaskan bagaimana kompatibilitas antara deployment dan data state terpengaruh setelah Anda memodifikasi fungsi agregat yang digunakan dengan GROUP BY dalam pernyataan SQL untuk deployment.	Group Aggregate
	Menjelaskan bagaimana kompatibilitas antara deployment dan data state terpengaruh setelah Anda memodifikasi fungsi agregat yang digunakan dengan OVER dalam pernyataan SQL untuk deployment.	Over Aggregate
	Menjelaskan bagaimana kompatibilitas antara deployment dan data state terpengaruh setelah Anda memodifikasi fungsi agregat window yang digunakan dengan GROUP BY dalam pernyataan SQL untuk deployment.	Group Window Aggregate
	Menjelaskan bagaimana kompatibilitas antara deployment dan data state terpengaruh setelah Anda memodifikasi fungsi tabel bernilai window (TVF) dalam pernyataan SQL untuk deployment.	Window TVF
	Menjelaskan bagaimana kompatibilitas antara deployment dan data state terpengaruh setelah Anda memodifikasi deduplikasi dalam pernyataan SQL untuk deployment.	Deduplikasi
	Menjelaskan bagaimana kompatibilitas antara deployment dan data state terpengaruh setelah Anda memodifikasi fungsi TopN dalam pernyataan SQL untuk deployment.	Top-N
	Menjelaskan bagaimana kompatibilitas antara deployment dan data state terpengaruh setelah Anda memodifikasi fungsi TopN berbasis window dalam pernyataan SQL untuk deployment.	Window Top-N
	Menjelaskan bagaimana kompatibilitas antara deployment dan data state terpengaruh setelah Anda memodifikasi join reguler, interval join, temporal join, atau lookup join dalam pernyataan SQL untuk deployment.	Join
	Menjelaskan bagaimana kompatibilitas antara deployment dan data state terpengaruh setelah Anda memodifikasi pengenalan pola dalam pernyataan SQL untuk deployment.	Pengenalan Pola
	Menjelaskan bagaimana kompatibilitas antara deployment dan data state terpengaruh setelah Anda memodifikasi klausa WHERE dalam pernyataan SQL untuk deployment.	Where
	Menjelaskan bagaimana kompatibilitas antara deployment dan data state terpengaruh setelah Anda memodifikasi UNION ALL dalam pernyataan SQL untuk deployment.	Union All
	Menjelaskan bagaimana kompatibilitas antara deployment dan data state terpengaruh setelah Anda memodifikasi pengurutan temporal dalam pernyataan SQL untuk deployment.	Temporal Sort
	Menjelaskan bagaimana kompatibilitas antara deployment dan data state terpengaruh setelah Anda memodifikasi klausa LIMIT dalam pernyataan SQL untuk deployment.	LIMIT
Memodifikasi konektor sumber	Menjelaskan bagaimana kompatibilitas antara deployment dan data state terpengaruh setelah Anda memodifikasi konektor sumber dalam pernyataan SQL untuk deployment.	Memodifikasi tabel sumber
Memodifikasi konektor sink	Menjelaskan bagaimana kompatibilitas antara deployment dan data state terpengaruh setelah Anda memodifikasi konektor sink dalam pernyataan SQL untuk deployment.	Mengubah konektor sink
Batasan lainnya	Menjelaskan batasan yang berlaku ketika Anda memodifikasi pernyataan SQL untuk deployment, tidak termasuk query, konektor sumber, dan konektor sink dari deployment.	Batasan lainnya

Tabel yang dibuat menggunakan pernyataan DDL berikut digunakan sebagai tabel sumber untuk pernyataan SQL sampel dalam skenario-skenario sebelumnya.

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 (
...);