本文为您介绍如何创建实时计算云数据库Phoenix结果表。

注意
  • 本文档仅适用于实时计算独享模式。
  • Blink-3.4.0以上版本支持Phoenix结果表。
  • Phoenix仅支持5.x版本。
  • Phoenix是云数据库HBase实例中的一种HBase SQL服务,须在云数据库HBase实例中开启此服务后才可以使用Phoenix。

DDL定义

实时计算支持使用Phoenix作为结果输出,示例代码如下。
create table US_POPULATION_SINK (
  `STATE` varchar,
  CITY varchar,
  POPULATION BIGINT,
  PRIMARY KEY (`STATE`, CITY)---主键必填。
) WITH (
  type = 'PHOENIX5',
  serverUrl = '<yourserverUrl>',
  tableName = '<yourTableName>'
);

With参数

参数 说明 是否必填 备注
serverUrl Phoenix5的Query Server地址:
  • 如果Phoenix5是在集群中创建的,则serverUrl是负载均衡服务的URL地址。
  • 如果Phoenix5是在单机中创建的,则serverUrl是单机的URL地址。
您需要在云数据库HBase实例中开启Hbase SQL服务,详情请参见开启HBase SQL服务
tableName 读取Phoenix表名。

代码示例

包含Phoenix结果表的实时计算作业代码示例如下。
create table `source` (
`id` varchar,
`name` varchar,
`age` varchar,
`birthday` varchar 
) WITH (
  type = 'random'
);

create table sink (
`id` varchar,
`name` varchar,
`age` varchar,
`birthday` varchar,
primary key (id)
) WITH (
  type = 'PHOENIX5',
  serverUrl = '<yourserverUrl>',
  tableName = '<yourTableName>'
);

INSERT INTO sink
SELECT  `id` ,`name` , `age` ,`birthday` 
FROM`source`;