Sparkcore和Sparksql完成经典TopN_sparkcore+sparksql-CSDN博客

网站介绍:文章浏览阅读2k次。数据是:import org.apache.spark.SparkContextimport org.apache.spark.rdd.RDDimport org.apache.spark.sql.{DataFrame, Row, SparkSession}object TopN { def main(args: Array[String]): Unit = { sparkcoreTopN() sparksqlTopN() } def sparkcoreTopN(_sparkcore+sparksql