一、创建临时视图 createorreplacetempView

package org.hnsw

import org.apache.spark.sql.SparkSession
//样本类 三个字段 userid(用户id)、artistid(艺术家ID)、playcount(播放次数)
case class UserArtist(userid:String, attiscleid:String, playcount:Int)
object SparkLearn {

  def main(args: Array[String]): Unit = {
    val session = SparkSession.builder().appName("jxq").master("local[*]").getOrCreate()
    //1、以rdd的方式读取文本
    val user_artist_dataRddjxq = session.sparkContext.textFile("file:///F:\user_artist_data.txt")
    //2.映射字段名 和 字段值
    val artRdd = user_artist_dataRddjxq.map((x)=>{
      val re = x.split(" ")
      UserArtist(re(0), re(1), re(2).trim.toInt)
    })
    //使用隐式函数,toDs
    import session.implicits._
    val ds = artRdd.toDS()
    //4、创建一个视图 createorreplacetempView
    ds.createOrReplaceTempView("user_artist_jxq")
    //5、使用sql查询语句
    session.sql("select * from user_artist_jxq").show()
    //6、释放sesion和视图表
    session.close()

  }
}

package org.hnsw

import org.apache.spark.sql.SparkSession

object SparkGloabalLearn {
  def main(args: Array[String]): Unit = {
    val session = SparkSession.builder().appName("jxq").master("local[*]").getOrCreate()
    //1、以rdd的方式读取文本
    val user_artist_dataRddjxq = session.sparkContext.textFile("file:///F:\user_artist_data.txt")
    //2.映射字段名 和 字段值
    val artRdd = user_artist_dataRddjxq.map((x)=>{
      val re = x.split(" ")
      UserArtist(re(0), re(1), re(2).trim.toInt)
    })
    //使用隐寺函数,toDs
    import session.implicits._
    val ds = artRdd.toDS()
    //4、创建一个视图 createGlobalTempView全局
    ds.createGlobalTempView("global_user_artist_jxq")
    //5、使用sql查询语句
    session.sql("select * from global_temp.global_user_artist_jxq").show()
    //6、释放sesion和视图表
    session.close()
  }

}