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

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

示例

从CloudTable的HBase中读取对象为car_infos的表。

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
CREATE SOURCE STREAM car_infos (
  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 = "carinfo",
    table_columns = "rowKey,info:owner,info:age,car:speed,car:miles"
); 
support.huaweicloud.com/sqlref-flink-dli/dli_08_0237.html