SparkStreaming之WordCount案例

一、案例简介 使用 netcat 工具向 9999 端口不断的发送数据,通过 SparkStreaming 读取端口数据并统 计不同单词出现的次数 。 二、netcat操作 1、虚拟机中安装netcat [root@hadoop1 spark]# yum install -y nc 2、启动程序并发送数据 [root@hadoop1 spark]# nc -lk 9999 三、代码实现 1、maven依赖 org.apache.spark spark-streaming_2.11 2.1.1 2、java代码 object SparkStreamingDemo { def main(arg