Fully managed Flink menyediakan berbagai templat kode. Setiap templat mencakup skenario penggunaan spesifik, contoh kode, dan instruksi sehingga Anda dapat memahami fitur dan sintaks Flink dengan cepat serta menerapkan logika bisnis Anda. Topik ini menjelaskan skenario penggunaan templat kode dan langkah-langkah untuk menggunakannya.
Batasan
Templat kode hanya didukung pada versi mesin komputasi waktu nyata vvr-4.0.12-flink-1.13 atau yang lebih baru.
Tindakan Pencegahan
Jika suatu templat tidak mencakup pernyataan INSERT INTO, pekerjaan tidak dapat dideploy.
Templat yang didukung
Tabel berikut menjelaskan templat yang didukung oleh Fully managed Flink beserta skenarionya. Untuk informasi terbaru, lihat Konsol.
|
Category |
Template name |
Scenario |
|
Basic templates |
Create Table |
Untuk membuat tabel dan menyimpannya dalam katalog, gunakan pernyataan Data Definition Language (DDL). Operasi pada tabel mirip dengan operasi pada database. |
|
Create Temporary Table |
Gunakan tabel temporary jika Anda hanya memerlukan tabel tersebut untuk session atau skrip SQL saat ini. |
|
|
Create Temporary View |
Untuk mengulang penggunaan kode, mengatur kueri panjang, atau menyederhanakan pengembangan dalam Flink SQL, gunakan temporary view. |
|
|
INSERT INTO |
Gunakan sintaks INSERT INTO untuk menulis hasil kueri ke tabel dalam sistem penyimpanan eksternal bagi aplikasi downstream. |
|
|
STATEMENT SET |
Gunakan sintaks STATEMENT SET untuk menulis hasil kueri ke dua atau lebih sistem eksternal downstream. |
|
|
Watermark |
Untuk memastikan Flink memproses data yang tidak berurutan secara benar, gunakan watermark. Anda dapat mendefinisikan watermark dalam pernyataan DDL tabel. Hal ini melibatkan pembuatan ekspresi generasi watermark pada bidang yang sudah ada dan menandai bidang tersebut sebagai atribut waktu. Untuk informasi selengkapnya, lihat Event Time and Watermarks. |
|
|
Aggregation and analysis |
GROUP BY |
Gunakan klausa GROUP BY untuk mengagregasi dan menganalisis data secara real-time. |
|
Tumbling window aggregation |
Gunakan jendela bergulir untuk mengelompokkan data deret waktu dan melakukan agregasi serta analisis pada data dalam setiap kelompok. |
|
|
Sliding window aggregation |
Gunakan jendela geser untuk memperbarui data dalam jendela pada interval tertentu. |
|
|
Cumulative window aggregation |
Gunakan jendela kumulatif untuk melihat hasil perhitungan lebih awal, misalnya untuk melihat hasil jendela terbaru setiap menit. Catatan
Agregasi jendela kumulatif tidak mendukung change data capture (CDC). Jika Anda menggunakan agregasi ini dengan CDC, akan muncul error validasi sintaks: |
|
|
Session window aggregation |
Gunakan jendela sesi untuk mengumpulkan statistik real-time pada data pengguna selama sesi aktif. |
|
|
Over window aggregation |
Gunakan jendela OVER untuk melakukan analisis statistik pada setiap elemen dalam jendela. |
|
|
Cascading window aggregation |
Gunakan jendela bertingkat untuk mengagregasi data dari aliran yang sama di berbagai dimensi waktu sekaligus, seperti 1 menit, 5 menit, 30 menit, dan 1 jam. |
|
|
Deduplication template |
Deduplication |
Gunakan sintaks deduplikasi untuk menghapus data duplikat dari aliran data. |
|
Top-N templates |
Top-N |
Gunakan sintaks Top-N untuk menghitung N catatan teratas atau terbawah berdasarkan kebutuhan bisnis. |
|
Window Top-N |
Gunakan sintaks Window Top-N untuk menghitung N catatan teratas atau terbawah dalam rentang waktu tertentu. |
|
|
CEP template |
Pattern detection (CEP) |
Gunakan sintaks MATCH_RECOGNIZE untuk mencari serangkaian pola event dalam aliran data. |
|
Join templates |
Regular Join |
Gunakan regular join untuk mengkueri dan menghitung data dengan menggabungkannya dengan aliran data lain. |
|
Interval Join |
Gunakan interval join untuk menggabungkan data dari tabel dalam rentang waktu tertentu. |
|
|
Temporal table join |
Gunakan temporal table join untuk menggabungkan setiap record dalam aliran dengan data versi yang sesuai di tabel lain. |
|
|
Dimension table join |
Gunakan dimension table join untuk menggabungkan data dengan tabel dimensi statis. |
Prosedur
Bagian ini menggunakan templat Create Table sebagai contoh untuk menunjukkan cara menggunakan templat kode.
-
Masuk ke Real-time Compute console.
-
Di kolom Actions untuk ruang kerja yang diinginkan, klik Console.
-
Pada halaman , klik New.
-
Pada tab SQL Basic Template, klik ganda templat yang diinginkan. Atau, pilih templat tersebut lalu klik Next di pojok kanan bawah.
-
Jika perlu, ubah File Name, Storage Location, Engine Version, dan kode SQL.
-
Klik Create.
Langkah-langkah selanjutnya sama seperti pengembangan pekerjaan standar. Untuk informasi selengkapnya, lihat Job development map.