Flink 实践教程-入门（5）：写入 ClickHouse原创

大家好，欢迎收看patchlink实战系列教程，本章结为入门系列5CONNECTOR，使用随机书写入到click house。腾讯云六计算OIST10大数据产品生态体系的实时化分析利器，兼容opalink作业。下面将教大家学习如何利用uist circle口作业，将data general产生的随机数据写入到click house z。Data general连接器是一种内置连接器，不需要额外的依赖项，利用内存的数据生成的创建表，默认情况下将创建无介流数据，每列都有一个随机值，此外也可以指定总行数，从而生成有界表。Click house不支持标准的更新和删除操作，若您的任务有更新和删除操作，可以通过collapse merge tree。来实现。接下来进入lotness控制台。点击左上角新建按钮，创建色口作业。

点击开发调试，进入作业编辑页面，首先创建source，点击插入模板，选择data general虚拟数据源表，然后创建S，点击插入模板，选择click house UD表写入。这里我为pton字段加上了水印，用于后续的窗口函数。请根据实际业务情况判断是否需要加上水印。

进入click house控制台，查看click house集群的相关配置参数。

这里需要注意选用HTTP方式的集群访问地址。接下来编写业务逻辑，这里模拟统计每分钟各用户的视频点击量。

Tumble start返回该窗口的起始时间，Tumble and返回该窗口的结束时间。

点击作业参数a connector选择CK连接器，也可以在引用程序包处选择自己开发的CK连接器。新版NK集群不需要用户自己选择内置connector。点击保存语法检查、发布草稿、运行测口作业。我们可以看到，作业已经处于运行中状态。作业运行后，可以从CVM连接click集群查看写入的数据。