L Q
SparkStreaming_MySQL SparkStreaming_MySQL
SparkStreaming_MySQL代码 object SparkMysql { def main(args: Array[String]): Unit = { val conf = new SparkConf().setA
2020-12-29
SparkStreaming_Kafka SparkStreaming_Kafka
SparkStreaming_Kafka代码 object SparkCount { def main(args: Array[String]): Unit = { val conf = new SparkConf().set
2020-12-29
SparkStreaming_HDFS SparkStreaming_HDFS
SparkStreaming_HDFSSpark Streaming 监控 Hadoop 的文件夹使用 SparkStreaming 之前,需要先初始化,初始化的代码如下: SparkConf conf = new SparkConf().
2020-12-29