如何分析基于SparkStreamingDirect方式的WordCount

这期内容当中小编将会给大家带来有关如何分析基于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了，如果刚好有类似的疑惑，不妨参照上述分析进行理解。如果想知道更多相关知识，欢迎关注创新互联行业资讯频道。