sparkWC MySql整合
import java.sql.DriverManager import com.typesafe.config.ConfigFactory import org.apache.spark.SparkConf import org.apache.spark.streaming.{Seconds, StreamingContext} object SparkStreamMySql { def main(args: Array[String]): Unit = { val config = ConfigFactory.load() val conf = new SparkCon
用户评论