1.8.9 大数据-Spark-StructuredStreaming流处理（socket , kfk）

本文主要是介绍1.8.9 大数据-Spark-StructuredStreaming流处理（socket , kfk），希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

环境准备1

• 启动nc传输消息安装见https://blog.csdn.net/tanxiang21/article/details/108760789

$ nc -lk 9999

演练

package com.spark.streaming.structuredimport org.apache.spark.sql.SparkSession
import org.apache.spark.sql.functions._
import org.apache.log4j.{Level, Logger}object TestStructured {Logger.getLogger("org").setLevel(Level.WARN)def main(args: Array[String]): Unit = {val spark = SparkSession.builder().master("local[2]").</

这篇关于1.8.9 大数据-Spark-StructuredStreaming流处理（socket , kfk）的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---