云数据库HBase版结果表

DDL定义

CREATE TABLE hbase_sink(
  rowkey INT,
  family1 ROW<q1 INT>,
  family2 ROW<q2 STRING, q3 BIGINT>,
  family3 ROW<q4 DOUBLE, q5 BOOLEAN, q6 STRING>
) with (
  'connector'='cloudhbase',
  'table-name'='<yourTableName>',
  'zookeeper.quorum'='<yourZookeeperQuorum>'
);

• HBase的列族（Column Family）必须声明为ROW类型，列族名即该ROW的字段名。例如，DDL定义中声明了family1、family2和family3三个列族。
• HBase列族中的列（Cloumn）与对应ROW中嵌套的每个字段对应，列名即字段名。例如，DDL定义中列族family2声明了q2和q3两列。
• 结果表中不需要将HBase表的所有列族和列都进行声明，只声明需要的即可。
• 除了类型为ROW的字段外，只能有一个原始类型（Atomic Type）的字段（例如STRING或BIGINT），该字段将被视作HBase的行键（Row Key），例如DDL定义中的rowkey。
• 必须将HBase的行键定义为结果表的主键(Primary Key)，如果没有显示定义主键，默认使用行键作为主键。

WITH参数

转换关系

动态表

CREATE TEMPORARY TABLE datagen_source (
    id INT,
    f1hour STRING,
    f1deal BIGINT,
    f2day STRING,
    f2deal BIGINT
) with (
    'connector'='datagen'
);

CREATE TEMPORARY TABLE hbase_sink (
    rowkey INT,
    f1 ROW<`hour` STRING, deal BIGINT>,
    f2 ROW<`day` STRING, deal BIGINT>
) with (
    'connector'='cloudhbase',
    'table-name'='<yourTableName>',
    'zookeeper.quorum'='<yourZookeeperQuorum>',
    'dynamic.table'='true'
);

INSERT INTO hbase_sink
SELECT id, ROW(f1hour, f1deal), ROW(f2day, f2deal) FROM datagen_source;

代码示例

CREATE TEMPORARY TABLE datagen_source (
   rowkey INT,
   f1q1 INT,
   f2q1 STRING,
   f2q2 BIGINT,
   f3q1 DOUBLE,
   f3q2 BOOLEAN,
   f3q3 STRING
) with (
   'connector'='datagen'
);

CREATE TEMPORARY TABLE hbase_sink (
   rowkey INT,
   family1 ROW<q1 INT>,
   family2 ROW<q1 STRING, q2 BIGINT>,
   family3 ROW<q1 DOUBLE, q2 BOOLEAN, q3 STRING>,
   PRIMARY KEY (rowkey) NOT ENFORCE
) with (
   'connector'='cloudhbase',
   'table-name'='<yourTableName>',
   'zookeeper.quorum'='<yourZookeeperQuorum>'
);
 
INSERT INTO hbase_sink
SELECT rowkey, ROW(f1q1), ROW(f2q1, f2q2), ROW(f3q1, f3q2, f3q3) FROM datagen_source;