MENJELASKAN - Lindorm

Pernyataan MENJELASKAN menampilkan detail dari sebuah Pekerjaan Flink.

Mesin dan versi

Pernyataan DESCRIBE hanya berlaku untuk mesin aliran dan memerlukan versi 3.1.8 atau lebih baru.

Catatan

Anda dapat menggunakan Konsol untuk melihat versi mesin dan melakukan pembaruan versi minor.

Sintaksis

describe_statement ::= { DESCRIBE | DESC } name

Catatan penggunaan

nama adalah nama dari Pekerjaan Flink. Anda dapat menggunakan pernyataan TAMPILKAN PEKERJAAN untuk melihat Pekerjaan Flink dalam kelompok sumber daya saat ini.

Contoh

Tampilkan detail dari pekerjaan datagen_job.

DESC datagen_job \G;

Catatan

Anda dapat menambahkan \G untuk menampilkan hasil dalam format vertikal agar lebih mudah dibaca.

Keluaran:

*************************** 1. baris ***************************
       ID Query: datagen_job
         ID Pekerjaan: 0021dcbf7633ed1b4c5a64a59591****
         Status: BERJALAN
   Dapat Dihentikan: salah
     Waktu mulai: 1753952195254
       Waktu akhir: -1
       Durasi: 61348039
Paralelisme Maks: -1
        DelayMs: -1,0
            Sql: 
  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',
    
    '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;