分类 标签 存档 黑客派 订阅 搜索

flink 0 篇文章

flink 自定义 TableSink 输出数据到控制台
[官方文档](https://flink-docs-cn.gitbook.io/project/05-ying-yong-kai-fa/04-table-api-and-sql/yong-hu-zi-ding-yi-sourcesink#ding-yi-tablesink) 中关于 TableSink 仅给出了接口名称和少量描述,关于接口方法的解释所提甚少。 为了能更好地理解 TableSink 的功能和实现方式,这里写了一个简单的场景: **读取一个英文文本文件,统计各单词出现的次数,并将统计结果转为 Table 对象,再把 Table 内容输出到控制台。**
阅读更多  
flink 自定义触发器实现带超时时间的 CountWindow
flink 的 window 有两个基本款,TimeWindow 和 CountWindow。 TimeWindow 是到时间就触发窗口,CountWindow 是到数量就触发。 如果我需要到时间就触发,并且到时间之前如果已经积累了足够数量的数据;或者在限定时间内没有积累足够数量的数据,我依然希望触发窗口业务,那么就需要自定义触发器。
阅读更多