Apache Flink 漫谈系列 - SQL概览

b. 使用

... 
val fun = new MyCount() 
tEnv.registerFunction("myCount", fun) 
val sql = "SELECT myCount(c) FROM MyTable GROUP BY a" 
... 

十三、Source&Sink

上面我们介绍了Apache Flink SQL核心算子的语法及语义，这部分将选取Bounded EventTime Tumble Window为例为大家编写一个完整的包括Source和Sink定义的Apache Flink SQL Job。假设有一张淘宝页面访问表(PageAccess_tab)，有地域，用户ID和访问时间。我们需要按不同地域统计每2分钟的淘宝首页的访问量(PV). 具体数据如下：

1. Source 定义

（编辑：晋中站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!