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
相關文章
相關標籤/搜索