Flink yang sepenuhnya dikelola menyediakan berbagai template kode. Setiap template mencakup skenario penggunaan, contoh kode, dan instruksi untuk membantu Anda memahami fitur serta sintaks Flink yang sepenuhnya dikelola dan mengimplementasikan logika bisnis Anda sendiri. Topik ini menjelaskan skenario penggunaan dan cara menggunakan template kode.
Batasan
Template kode hanya tersedia di Realtime Compute for Apache Flink dengan versi mesin vvr-4.0.12-flink-1.13 atau yang lebih baru.
Perhatian
Jika template kode yang digunakan dalam draf tidak mengandung pernyataan INSERT INTO, draf tersebut tidak dapat diterapkan.
Template kode yang didukung
Tabel berikut menjelaskan template kode yang disediakan oleh Flink yang sepenuhnya dikelola beserta skenario penggunaannya. Template ini dapat ditemukan di konsol Flink yang sepenuhnya dikelola.
Kategori | Nama template | Skenario |
Template dasar | Buat Tabel | Jika Anda ingin membuat tabel dan menyimpan tabel tersebut dalam katalog, Anda dapat mengeksekusi pernyataan CREATE TABLE. Operasi pada tabel serupa dengan operasi pada database. |
Buat Tabel Sementara | Jika Anda ingin menggunakan tabel hanya dalam sesi saat ini atau dalam skrip SQL, Anda dapat mengeksekusi pernyataan CREATE TEMPORARY TABLE untuk membuat tabel sementara. | |
Buat Tampilan Sementara | Jika Anda ingin menggunakan kembali kode, membuat kueri panjang, atau menulis skrip SQL untuk menyederhanakan pengembangan draf saat mengembangkan draf SQL Flink, Anda dapat mengeksekusi pernyataan CREATE TEMPORARY VIEW untuk membuat tampilan sementara. | |
INSERT INTO | Jika Anda ingin menulis hasil kueri ke tabel dalam sistem penyimpanan hilir, Anda dapat mengeksekusi pernyataan INSERT INTO. | |
STATEMENT SET | Jika Anda ingin menulis hasil kueri ke dua atau lebih sistem penyimpanan hilir, Anda dapat menggunakan sintaks STATEMENT SET. | |
Watermark | Jika Anda ingin Flink yang sepenuhnya dikelola memproses data yang tidak berurutan sesuai harapan, Anda dapat menggunakan klausa WATERMARK dalam pernyataan DDL. Anda dapat menggunakan klausa WATERMARK dalam pernyataan DDL CREATE TABLE untuk membuat watermark. Klausa ini mendefinisikan ekspresi untuk menghasilkan watermark berdasarkan bidang yang ada dan menandai bidang tersebut sebagai bidang atribut waktu. Untuk informasi lebih lanjut, lihat Event Time and Watermarks. | |
Template agregasi dan analisis | GROUP BY | Jika Anda ingin mengumpulkan dan menganalisis data secara real-time, Anda dapat menggunakan klausa GROUP BY. |
Agregasi Jendela Tumble | Jika Anda ingin mengelompokkan data deret waktu dan mengumpulkan serta menganalisis data dalam setiap kelompok, Anda dapat menggunakan fungsi TUMBLE. | |
Agregasi Jendela Hop | Jika Anda ingin memperbarui data dalam jendela pada interval tertentu, Anda dapat menggunakan fungsi HOP. | |
Agregasi Jendela Kumulatif | Jika Anda ingin melihat hasil perhitungan jendela sebelum waktunya, seperti melihat hasil terbaru dari jendela dengan interval satu menit, Anda dapat menggunakan fungsi CUMULATE. null Fungsi CUMULATE tidak dapat digunakan untuk mengumpulkan data Change Data Capture (CDC). Jika Anda menggunakan fungsi CUMULATE untuk mengumpulkan data CDC, pesan kesalahan | |
Agregasi Jendela Sesi | Jika Anda ingin mengumpulkan statistik data dalam sesi aktif secara real-time, Anda dapat menggunakan fungsi SESI. | |
Agregasi Jendela Over | Jika Anda ingin melakukan analisis statistik pada setiap elemen dalam jendela, Anda dapat menggunakan jendela OVER. | |
Agregasi Jendela Berantai | Jika Anda ingin mengumpulkan data dari aliran yang sama dalam dimensi waktu yang berbeda, seperti 1 menit, 5 menit, 30 menit, atau 1 jam, Anda dapat menggunakan jendela berantai. | |
Template deduplikasi | Deduplikasi | Jika Anda ingin menghapus data duplikat dari aliran data, Anda dapat menggunakan sintaks deduplikasi. |
Template Top-N | Top-N | Jika Anda ingin mengurutkan hasil komputasi secara ascending atau descending berdasarkan kebutuhan bisnis Anda dan mendapatkan N catatan data pertama, Anda dapat menggunakan sintaks Top-N. |
Window Top-N | Jika Anda ingin mengurutkan hasil komputasi secara ascending atau descending dan mendapatkan N catatan data pertama dalam rentang waktu tertentu, Anda dapat menggunakan sintaks window Top-N. | |
Template pemrosesan peristiwa kompleks (CEP) | Pengenalan Pola | Jika Anda ingin mencari sekumpulan pola peristiwa dalam aliran data, Anda dapat menggunakan sintaks MATCH_RECOGNIZE. |
Template JOIN | Regular Join | Jika Anda ingin melakukan kueri join pada data tabel dan tabel aliran, Anda dapat menggunakan regular join. |
Interval Join | Jika Anda ingin melakukan kueri join pada data tabel dan tabel aliran dalam periode waktu tertentu, Anda dapat menggunakan interval join. | |
Temporal Join | Jika Anda ingin melakukan kueri join pada data tabel aliran dan data versi waktu terkait di tabel lain, Anda dapat menggunakan temporal join. | |
Look-up Join | Jika Anda ingin melakukan kueri join pada data tabel dimensi statis dan tabel aliran, Anda dapat menggunakan look-up join. |
Prosedur
Berikut adalah langkah-langkah menggunakan template kode. Contoh ini menggunakan template Create Table.
Temukan ruang kerja yang ingin dikelola dan klik Console di kolom Actions.
Di panel navigasi sebelah kiri, klik . Di pojok kiri atas halaman Penyunting SQL, klik New.
Pada tab SQL Scripts kotak dialog Draf Baru, klik dua kali nama template yang diinginkan. Atau, klik nama template dan pilih Next di pojok kanan bawah kotak dialog.
Di bagian Draft Configuration, konfigurasikan parameter Name, Location, dan Engine Version sesuai kebutuhan bisnis Anda. Di bagian Preview, tulis kode SQL.
Klik Create.
Langkah selanjutnya sama dengan proses pengembangan draf. Untuk informasi lebih lanjut tentang pengembangan draf, lihat Mengembangkan draf SQL.