基于scala的spark on yarn历史统计程序

我的测试程序代码: 1.写好scala代码 功能:从hdfs读取数据,然后处理后输出到hdfs import org.apache.spark.sql.{Dataset, SparkSession} object TestLoadDbData { def main(args: Array[String]): Unit = { if (args.size != 1) { p
相关文章
相关标签/搜索