标签：转换 val ------------------ frame dataFrame DataFrame 算子 println select

val sparkConf = new SparkConf().setMaster("local[2]").setAppName("tran")
val sparkSession = SparkSession.builder().config(sparkConf).getOrCreate()

val seq:Seq[Student] = Array(Student("zs",20,"男"),Student("ls",21,"女"),Student("ww",22,"男"))
val rdd:RDD[Student] = sparkSession.sparkContext.makeRDD(seq)
val dataFrame:DataFrame = sparkSession.createDataFrame(rdd,classOf[Student])

case class Student(@BeanProperty var name:String,@BeanProperty var age:Int,@BeanProperty var sex:String)

limit

def limitOpt(dataFrame: DataFrame): Unit = {
  println("------------------limit操作开始------------------")
  // select name,age from student limit 2
  val frame: DataFrame = dataFrame.limit(2).select("name", "age")
  frame.show()
  println("------------------limit操作结束------------------")
}

where

def whereOpt(dataFrame: DataFrame) = {
  // select * from student where age>21
  println("------------------where操作开始------------------")
  val frame = dataFrame.where("age > 21").select("*")
  frame.show()
  println("------------------where操作结束------------------")
  println("------------------filter操作开始------------------")
  val frame1 = dataFrame.filter("age > 21").select("*")
  frame1.show()
  println("------------------filter操作结束------------------")
}

select

def selectOpt(dataFrame: DataFrame) = {
  println("------------------select操作开始------------------")
  val frame = dataFrame.select("name", "age")
  frame.show()
  println("------------------select操作结束------------------")
}

def selectExprOpt(dataFrame: DataFrame) = {
  println("------------------selectExpr操作开始------------------")
  val frame = dataFrame.selectExpr("name as na", "age as ag")
  frame.show()
  println("------------------selectExpr操作结束------------------")
}

标签：转换,val,------------------,frame,dataFrame,DataFrame,算子,println,select
来源： https://www.cnblogs.com/jsqup/p/16637891.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。