Pekerjaan memungkinkan Anda menggunakan sintaksis SQL Flink open-source untuk mengimplementasikan logika komputasi aliran seperti penyaringan, transformasi, peningkatan, dan agregasi. Hasilnya kemudian ditulis ke Lindorm.
Mesin dan versi
Pernyataan BUAT PEKERJAAN hanya berlaku untuk mesin aliran. Diperlukan versi 3.1.8 atau yang lebih baru.
Anda dapat memeriksa versi mesin dan melakukan pembaruan versi minor di Konsol.
Sintaksis
delimiter $$
create_job_statement ::= CREATE JOB job_name
'('
flink_sqls
')'
$$
delimiter ;Catatan penggunaan
Nama Pekerjaan Flink (job_name)
Wajib. Nama Pekerjaan Flink harus memenuhi persyaratan berikut:
Dapat berisi huruf, angka, titik (.), tanda hubung (-), dan garis bawah (_).
Tidak boleh dimulai dengan titik (.) atau tanda hubung (-).
Panjangnya harus antara 1 hingga 255 karakter.
Pernyataan SQL Flink (flink_sqls)
Wajib. Pernyataan ini mendefinisikan logika komputasi. Untuk informasi lebih lanjut tentang sintaksis, lihat dokumentasi komunitas Flink.
Contoh
Contoh ini mencetak data yang dihasilkan secara acak.
delimiter $$
CREATE JOB datagen_job (
SET 'parallelism.default' = '6';
CREATE TABLE datagen (
f_sequence INT,
f_random INT,
f_random_str STRING,
ts AS localtimestamp,
WATERMARK FOR ts AS ts
) WITH (
'connector' = 'datagen',
-- opsi opsional --
'rows-per-second'='5',
'fields.f_sequence.kind'='sequence',
'fields.f_sequence.start'='1',
'fields.f_sequence.end'='50000000',
'fields.f_random.min'='1',
'fields.f_random.max'='500',
'fields.f_random_str.length'='10'
);
CREATE TABLE print_table (
f_sequence INT,
f_random INT,
f_random_str STRING
) WITH (
'connector' = 'print'
);
INSERT INTO print_table select f_sequence,f_random,f_random_str from datagen;
)
$$
delimiter ;Verifikasi hasil
Anda dapat menjalankan pernyataan SHOW JOBS; untuk memverifikasi bahwa pekerjaan telah berhasil dibuat.