09【在线日志分析】之基于Spark Streaming Direct方式的WordCount最详细案例(java版)
1.前提 a. flume 收集--》flume 聚合--》kafka ,启动进程和启动kafka manager监控 08【在线日志分析】之Flume Agent(聚合节点) sink to kafka cluster 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:...