Flink Table API示例

Source&Sink 咱们选取Bounded EventTime Tumble Window为例,编写一个完整的包括Source和Sink定义的Apache Flink Table API Job。假设有一张淘宝页面访问表(PageAccess_tab),有地域,用户ID和访问时间。咱们须要按不一样地域统计每2分钟的淘宝首页的访问量(PV)。具体数据以下:java region userId a
相关文章
相关标签/搜索