本文主要是介绍Blink SQL之创建数据总线DataHub源表,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
创建数据总线DataHub源表
适用于Blink 1.4.5及以上版本。
什么是数据总线
阿里云流数据处理平台DataHub是流式数据(Streaming Data)的处理平台,提供对流式数据的发布(Publish)、订阅(Subscribe)和分发功能,让您可以轻松构建基于流式数据的分析和应用。实时计算Flink版使用DataHub作为流式数据存储源头或输出目的端。
语法示例
DataHub可以作为实时计算Flink版的数据输入,示例如下。
CREATE TABLE datahub_stream(name VARCHAR,age BIGINT,birthday BIGINT
) WITH (type='datahub',endPoint='http://dh-cn-hangzhou.aliyun-inc.com',project='<yourProjectName>',topic='<yourTopic>',accessId='<yourAccessID>',accessKey='<yourAccessSecret>',startTime='2017-07-21 00:00:00'
这篇关于Blink SQL之创建数据总线DataHub源表的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!