Realtime Compute for Apache Flink：管理StarRocks Catalog

UI方式

1. 進入中繼資料管理頁面。

   1. 登入Realtime Compute控制台，單擊目標工作空間操作列下的控制台。

   2. 單擊中繼資料管理。

2. 單擊建立Catalog，選擇StarRocks，單擊下一步。

3. 填寫參數配置資訊。

   重要

   Catalog建立完成後，以下配置資訊都不支援修改。如果需要修改，則您需要刪除掉已建立的Catalog，重新進行建立。

   

   配置項	說明	是否必填	備忘
   catalog name	StarRocks Catalog名稱。	是	僅支援小寫字母a-z和數字0-9，不含大寫字母、中劃線（-）、底線（_）等特殊字元。
   endpoint	StarRocks的FE（Front End）訪問地址。	是	指定FE的IP和JDBC連接埠，格式為jdbc:mysql://ip:port。一般為9030。
   dbname	訪問StarRocks的預設資料庫名稱。	是	無。
   username	訪問StarRocks的使用者名稱。	是	無。
   password	訪問StarRocks的密碼。	是	為了避免您的密碼泄露，建議您通過密鑰管理的方式填寫密碼取值，詳情請參見變數和密鑰管理。

4. 單擊確定。

5. 在左側中繼資料地區，查看建立的Catalog。

SQL命令

1. 在查詢指令碼文本編輯地區，輸入建立StarRocks Catalog的命令。

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

   配置項	說明	是否必填	備忘
   catalogname	StarRocks Catalog名稱。	是	僅支援小寫字母a-z和數字0-9，不含大寫字母、中劃線（-）、底線（_）等特殊字元。
   type	類型。	是	固定值為starrocks。
   endpoint	StarRocks的FE（Front End）訪問地址。	是	指定FE的IP和JDBC連接埠，格式為jdbc:mysql://ip:port。一般為9030。
   username	訪問StarRocks的使用者名稱。	是	無。
   password	訪問StarRocks的密碼。	是	為了避免您的密碼泄露，建議您通過密鑰管理的方式填寫密碼取值，詳情請參見變數和密鑰管理。
   dbname	訪問StarRocks的預設資料庫名稱。	是	無。

2. 選中建立Catalog的代碼後，單擊左側程式碼數上的運行。

   

從StarRocks表中讀取資料

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')
    */

寫入結果資料至StarRocks表

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}

作為CTAS&CDAS的目標端Catalog

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};

詳情請參見基於Realtime ComputeFlink使用CTAS&CDAS功能同步MySQL資料至StarRocks。

UI方式

1. 進入中繼資料管理頁面。

   1. 登入Realtime Compute控制台。

   2. 單擊目標工作空間操作列下的控制台。

   3. 單擊中繼資料管理。

2. 在Catalog列表頁面，單擊目標Catalog名稱對應操作列的刪除。

3. 在彈出的提示頁面中，單擊刪除。

4. 左側中繼資料地區下，查看目標Catalog是否已刪除。

SQL命令方式

1. 在查詢指令碼文本編輯地區，輸入以下命令。

   DROP CATALOG `<catalog name>`;

   其中，<catalog name>是您StarRocks Catalog的名稱。

   重要

   刪除StarRocks Catalog不會影響已啟動並執行作業，但對未上線或者作業需要暫停恢複的作業均產生影響，請您謹慎操作。

2. 選中刪除Catalog的命令，滑鼠右鍵選擇運行。

3. 在左側中繼資料地區，查看目標Catalog是否已刪除。