flink小例子之side output 、table、sql、多sink的使用

前沿 這個小例子主要介紹了flink side output 、table、sql、多sink的使用，從一個源消費流數據，而後主流數據存入hdfs，從主流數據引出side output數據，對側輸出數據進行處理，按一秒的窗口計算出pv，平均響應時間，錯誤率（status不等於200的佔比）等，而後將計算結果寫入本地的cvs。java 自定義source import org.apache.flin

>>阅读原文<<