溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這期內容當中小編將會給大家帶來有關如何分析基于Spark Streaming Direct方式的WordCount，文章內容豐富且以專業的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。
1.前提
a. flume 收集--》flume 聚合--》kafka ，啟動進程和啟動kafka manager監控
b.window7 安裝jdk1.7 或者1.8(本次環境是1.8)
c.window7 安裝IDEA開發工具(以下僅供參考)
使用IntelliJ IDEA 配置Maven（入門）: http://blog.csdn.net/qq_32588349/article/details/51461182
IDEA Java/Scala混合項目Maven打包 :http://blog.csdn.net/rongyongfeikai2/article/details/51404611
Intellij idea使用java編寫并執行spark程序: http://blog.csdn.net/yhao2014/article/details/44239021
2.源代碼 （可下載單個java文件，加入projet 或者 整個工程下載，IDEA選擇open 即可）
GitHub: https://github.com/Hackeruncle/OnlineLogAnalysis/blob/master/online_log_analysis/src/main/java/com/learn/java/main/SparkStreamingFromKafka_WordCount.java
3.使用IDEA 本地運行測試（未打jar包）
上述就是小編為大家分享的如何分析基于Spark Streaming Direct方式的WordCount了，如果剛好有類似的疑惑，不妨參照上述分析進行理解。如果想知道更多相關知識，歡迎關注億速云行業資訊頻道。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
