Spark Streaming和Flink的Word Count對比

準備: nccat for windows/linux 均可以 經過 TCP 套接字鏈接,從流數據中建立了一個 Spark DStream/ Flink DataSream, 而後進行處理, 時間窗口大小爲10s  由於 示例須要, 因此 須要下載一個netcat, 來構造流的輸入。java 代碼: spark streaminglinux package cn.kee.spark; public
相關文章
相關標籤/搜索