Lv.2
潇湘暮雨
更多个人资料
60
成长值
2
关注
2
粉丝
+ 关注
私信
个人介绍
这个人很懒,什么都没有留下
感兴趣或擅长的领域
暂无数据
个人勋章
TA还没获得勋章~
成长雷达
60
0
0
0
0
个人资料
个人介绍
这个人很懒,什么都没有留下
感兴趣或擅长的领域
暂无数据
达成规则
以上满足
项可达成此勋章
博客
关注
粉丝
论坛
全部时间
全部时间
最近三天
最近一周
最近一月
全部
暂无专栏分类
DLI Flink OpenSource SQL中用户自定义sink的使用
在DLI的Flink OpenSource SQL语句中针对用户不同的使用场景,为用户提供了较多的connector以供用户使用,如DWS connector、kafka connector、RDS connector、Hbase connector和elasticsearch connector等。虽然这些connector足够应付大多数主流使用场景,但是仍然有可能不能够满...
EI企业智能
数据湖探索 DLI
智能数据
潇湘暮雨
2021-09-30 09:07:30
7161
0
0
2021-09-30 09:07:30
999+
0
0
Flink JDBC Connector sink源码简单阅读
对于connector的介绍之前已经讲解,此处就不再详细结果其运行流程和使用方式,而是简单学习下jdbc connector中sink的源码,而由于源码较多因此我们只挑选重点部分进行研究学习。1 JDBCTableSourceSinkFactory:JDBC支持的配置属性参数在flink sql中,所有的connector的使用都是从factory开始的,而factory的创建是通...
EI企业智能
数据湖探索 DLI
智能数据
潇湘暮雨
2021-08-09 21:01:06
4645
0
0
2021-08-09 21:01:06
999+
0
0
DLI中Flink使用场景样例介绍(一)
DLI是数据湖探索(Data Lake Insight)的简称,它是完全兼容Apache Spark、Apache Flink、openLooKeng(基于Apache Presto)生态,提供一站式的流处理、批处理、交互式分析的Serverless融合处理分析服务。用户不需要管理任何服务器,即开即用。支持标准SQL/Spark SQL/Flink SQL,支持多种接入方式,并...
EI企业智能
数据湖探索 DLI
智能数据
潇湘暮雨
2021-05-08 09:40:57
7019
0
0
2021-05-08 09:40:57
999+
0
0
Flink SQL中的WindowOperator
在流处理的实际应用中,数据是连续不断的,因此我们不可能等待所有的数据都到了才开始处理。虽然我们可以对每来一条数据就处理一次,但是有一些场景我们需要使用一段时间内的数据进行计算,比如统计在一分钟内用户对某商品的浏览量,而这就是window窗口的使用场景。Flink sql中对于窗口的使用主要是通过TUMBLE、HOP和SESSION,而这些操作都是基于WindowOperato...
智能数据
EI企业智能
数据湖探索 DLI
潇湘暮雨
2020-12-27 20:24:16
6896
0
0
2020-12-27 20:24:16
999+
0
0
Flink SQL中connector的定义和实现
在FLink SQL中一般是以create Table和connector结合的形式读取外部数据,从而创建table,如下是以JDBC作为connector的创建格式:CREATE TABLE MyUserTable ( ...) WITH ( 'connector.type' = 'jdbc', 'connector.url' = 'jdbc:mysql://localhost:33...
EI企业智能
智能数据
数据湖探索 DLI
潇湘暮雨
2020-09-28 19:52:23
10594
0
0
2020-09-28 19:52:23
999+
0
0
Flink入门学习笔记
Flink入门学习笔记
EI企业智能
智能数据
数据湖探索 DLI
潇湘暮雨
2020-08-11 15:14:57
7373
0
1
2020-08-11 15:14:57
999+
0
1
https://www.baidu.com/s?ie=utf-8&f=3&rsv_bp=0&rsv_idx=1&tn=baidu&wd=sed%20%E6%9B%BF%E6%8D%A2%E5%AD%97%E7%AC%A6%E4%B8%B2&rsv_pq=c7db61a600035dc5&rsv_t=5e19yEsbV9N5fIvdlGRU
+ 关注