首页 > 数据库> 文章详细

Blink SQL之创建交互式分析Hologres源表

2022-01-27 20:36:10 阅读：213 来源： 互联网

标签：... 读取 Blink BIGINT SQL 源表 Hologres

创建交互式分析Hologres源表

使用限制

适用于Blink 3.6.0及以上版本。

注意事项

在流数据和批数据处理中都可以使用Hologres源表。
Hologres源表支持Projection Pushdown操作，您可以只读取需要的列。
Hologres源表使用快照语句高速读取当前数据，读取完后结束作业。如果出现读取数据失败，将重新执行读取操作。
并发的Blink作业都可以读取一个或多个Hologres Shard，建议您配置的Blink并发数小于等于Hologres的Shard数。
实时消费Hologres源表的数据需要开启Binlog。

DDL定义

create table mysource(
  name varchar,
  age BIGINT,
  birthday BIGINT
) with (
  type='hologres',
  dbname='...',
  tablename='...',
  username='...',
  password='...',
  endpoint='...',
  field_delimiter='...' --该参数可选。
);

WITH参数

参数	说明	是否必填	备注
type	源表类型	是	固定值为hologres。
dbname	数据库名称	是	无
tablename	表名称 `如果Schema不为Public时，则tableName需要填写为schema.tableName。`	是	无
username	用户名，请填写阿里云账号的AccessKey ID。	是	无
password	密码，请填写阿里云账号的AccessKey Secret。	是	无
endpoint	Hologres端点	是	详情请参见访问域名。
field_delimiter	导出数据时，不同行之间使用的分隔符。 `不能在数据中插入分隔符。`	是	默认值为"\u0002"。
bulkread	是否全量读取列存表数据。	否	取值如下： true：全量读取列存表数据。 false（默认值）：不全量读取列存表数据。

类型映射

Hologres	BLINK
INT	INT
INT[]	ARRAY
BIGINT	BIGINT
BIGINT[]	ARRAY
REAL	FLOAT
REAL[]	ARRAY
DOUBLE PRECISION	DOUBLE
DOUBLE PRECISION[]	ARRAY
BOOLEAN	BOOLEAN
BOOLEAN[]	ARRAY
TEXT	VARCHAR
TEXT[]	ARRAY
NUMERIC	DECIMAL
DATE	DATE
TIMESTAMP WITH TIMEZONE	TIMESTAMP

代码示例

create table mysource(
  name varchar,
  age BIGINT,
  birthday BIGINT
) with (
  type='hologres',
  dbname='...',
  tablename='...',
  username='...',
  password='...',
  endpoint='...',
  field_delimiter='...' --该参数可选。
);


create table print_output(
 a varchar,
 b BIGINT,
 c BIGINT 
) with (
  type='print'
);


INSERT INTO print_output
SELECT 
  a, b, c
from mysource;

标签：...,读取,Blink,BIGINT,SQL,源表,Hologres
来源： https://blog.csdn.net/shenglishuguang/article/details/122723182

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9