本文为您介绍Phoenix5结果表DDL定义、WITH参数和代码示例。
DDL定义
create table phoenix5_sink (
`STATE` varchar,
CITY varchar,
POPULATION BIGINT,
PRIMARY KEY (`STATE`, CITY)
) WITH (
'connector' = 'phoenix5',
'serverUrl' = '<yourserverUrl>',
'tableName' = '<yourTableName>',
'batchsize' = '25'
);
WITH参数
参数 | 说明 | 是否必填 | 备注 |
---|---|---|---|
connector | 结果表类型 | 是 | 默认值为phoenix5 。
|
serverUrl | Phoenix5的Query Server地址:
|
是 | 您需要在云数据库HBase实例中开启Hbase SQL服务,详情请参见开启HBase SQL服务。 |
tableName | Phoenix5表名 | 是 | 无 |
batchSize | 一次批量写入的条数 | 否 | 默认值为20。 |
代码示例
包含Phoenix5结果表的Flink作业代码示例如下。
CREATE TEMPORARY table datagen_source (
`id` varchar,
`name` varchar,
`age` varchar,
`birthday` varchar
) WITH (
'connector' = 'datagen'
);
CREATE TEMPORARY table phoenix5_sink (
`id` varchar,
`name` varchar,
`age` varchar,
`birthday` varchar,
primary key (id)
) WITH (
'connector' = 'phoenix5',
'serverurl' = '<yourserverUrl>',
'tablename' = '<yourTableName>',
'batchsize' = '25'
);
INSERT INTO phoenix5_sink
SELECT `id` ,`name` , `age` ,`birthday`
FROM datagen_source;
在文档使用中是否遇到以下问题
更多建议
匿名提交