Realtime Compute for Apache Flink:Kelola katalog StarRocks

Buat katalog StarRocks di Konsol

1. Login ke Konsol Realtime Compute for Apache Flink. Temukan ruang kerja yang ingin Anda kelola dan klik Console pada kolom Actions.

2. Di panel navigasi sebelah kiri, klik Catalogs.

3. Pada halaman Catalog List, klik Create Catalog. Di wizard Create Catalog, pilih StarRocks pada tab Built-in Catalog, lalu klik Next.

4. Konfigurasikan parameter katalog.

   Penting

   Konfigurasi katalog StarRocks tidak dapat diubah setelah dibuat. Untuk mengganti pengaturan apa pun, hapus katalog yang ada dan buat katalog baru.

   Parameter	Deskripsi	Wajib	Catatan
   catalog name	Nama katalog StarRocks.	Ya	Hanya huruf kecil dan angka. Tanda hubung (-), garis bawah (_), dan huruf kapital tidak diperbolehkan.
   endpoint	Titik akhir node FrontEnd (FE).	Ya	Format: jdbc:mysql://ip:port. Port JDBC default adalah 9030.
   dbname	Database StarRocks default yang akan dihubungi.	Ya	—
   username	Username untuk mengakses StarRocks.	Ya	—
   password	Password untuk mengakses StarRocks.	Ya	Gunakan variabel alih-alih password dalam teks biasa untuk menghindari eksposur kredensial. Lihat Manage variables.

   

5. Klik Confirm.

Katalog tersebut muncul di halaman Catalog List.

Buat katalog StarRocks menggunakan Flink SQL

Di editor SQL pada halaman Scripts, masukkan pernyataan CREATE CATALOG, pilih pernyataan tersebut, lalu klik Run di sisi kiri.

CREATE CATALOG <catalogname> WITH (
  'type' = 'starrocks',
  'endpoint' = '<ip>:<port>',
  'username' = '<userName>',
  'password' = '<password>',
  'dbname' = '<dbname>'
);

Opsi konfigurasi berbeda tergantung pada versi VVR Anda.

Baca data dari tabel StarRocks

INSERT INTO ${other_sink_table}
SELECT ...
FROM `${catalog_name}`.`${db_name}`.`${table_name}`

INSERT INTO ${other_sink_table}
SELECT ...
FROM `${catalog_name}`.`${db_name}`.`${table_name}`
    /*+
        OPTIONS('connector' = 'starrocks', 'jdbc-url' = 'jdbc:mysql://ip:port', 'scan-url' = 'ip:port')
    */

Tulis data ke tabel StarRocks

INSERT INTO `${catalog_name}`.`${db_name}`.`${table_name}`
SELECT ...
FROM ${other_source_table}

INSERT INTO `${catalog_name}`.`${db_name}`.`${table_name}`
    /*+
        OPTIONS('connector' = 'starrocks', 'jdbc-url' = 'jdbc:mysql://ip:port', 'load-url' = 'ip:port', 'sink.buffer-flush.interval-ms' = '5000', 'sink.properties.row_delimiter' = '\x02', 'sink.properties.column_separator' = '\x01')
    */
SELECT ...
FROM ${other_source_table}

Gunakan CTAS atau CDAS untuk menulis ke StarRocks

CTAS (CREATE TABLE AS SELECT) dan CDAS (CREATE DATABASE AS DATABASE) memungkinkan Anda membuat tabel atau database StarRocks dari sumber yang sudah ada dalam satu pernyataan.

USE CATALOG sr_catalog;

CREATE TABLE IF NOT EXISTS `${table_name}`
WITH (
  ...
) AS TABLE ${other_source_table};


CREATE DATABASE IF NOT EXISTS `${db_name}`
WITH (
  ...
) AS DATABASE ${other_source_database};

Untuk panduan lengkap, lihat Ingest data from MySQL to StarRocks with Flink.

Hapus katalog StarRocks di Konsol

1. Login ke Konsol Realtime Compute for Apache Flink. Temukan ruang kerja yang Anda inginkan dan klik Console pada kolom Actions.

2. Di panel navigasi sebelah kiri, klik Catalogs.

3. Di halaman Catalog List, temukan katalog tersebut dan klik Delete pada kolom Actions.

4. Di dialog konfirmasi, klik Delete.

Katalog tersebut dihapus dari panel Catalogs di navigasi sebelah kiri.

Hapus katalog StarRocks menggunakan Flink SQL

Di editor SQL pada halaman Scripts, masukkan pernyataan berikut, klik kanan pernyataan tersebut, lalu pilih Run.

DROP CATALOG `<catalog name>`;

Ganti <catalog name> dengan nama katalog yang ingin Anda hapus.

Setelah pernyataan dijalankan, verifikasi bahwa katalog telah dihapus dengan memeriksa panel Catalogs di navigasi sebelah kiri.