隐式装换

Posted 2021-02-20 xjqi

 1 package com.ds
 2 
 3 import org.apache.spark.sql.{Dataset, SparkSession}
 4 
 5 object DataSet {
 6 
 7   def main(args: Array[String]): Unit = {
 8     val spark: SparkSession = SparkSession.builder().appName("DataSet").master("local[2]").getOrCreate()
 9     //需要导入隐式装换
10     import spark.implicits._
11     //创建dataframe的方式1
12     val ds: Dataset[Int] = spark.createDataset(0 to 10)
13     ds.show()
14     spark.stop()
15   }
16 
17 }