从零开始写一个Spark Structured Streaming程序来统计单词个数

本文将从零开始写一个Spark Structured Streaming程序来统计单词的个数。单词的来源是socket,读者也可以换成kafka,计算的结果输出到控制台,读者也可以改成输出到kafka的某个topic。 准备环境: JDK和Scala安装,并配置好环境变量JAVA_HOME和SCALA_HOME下面是配置好的环境信息: pilafiMac:~ pilaf$ java -versio
相关文章
相关标签/搜索