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 界说

（编辑：湖南网）

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