数据湖探索 DLI-CloudTable HBase输出流:示例

时间：2024-11-16 13:21:40

数据湖探索 DLI

示例

将流qualified_cars的数据输出到表格存储服务 CloudTable的HBase中。

  
   
     
     
       CREATE SINK STREAM qualified_cars (
  car_id STRING,
  car_owner STRING,
  car_age INT,
  average_speed INT,
  total_miles INT
)
  WITH (
    type = "cloudtable",
    region = "xxx",
    cluster_id = "209ab1b6-de25-4c48-8e1e-29e09d02de28",
    table_name = "car_pass_inspect_with_age_${car_age}",
    table_columns = "rowKey,info:owner,,car:speed,car:miles",
    illegal_data_table = "illegal_data",
    create_if_not_exist = "true",
    batch_insert_data_num = "20"
);

      

    

  
 