分类：mysql
Spark Structured Streaming从kafka读数据 并进行wordcount 更新写入mysql
def main(args: Array[String]): Unit = { val sparkSession: SparkSession = SparkSession.builder().master("local[…
centos mysql部署
https://dev.mysql.com/downloads/repo/yum/ 一、安装 MySQL 的 yum 源 # 安装源，会在 /etc/yum.repos.d/ 下生成 mysql-community.re…