@prudhvi ramalingam——請參閱下麵的示例代碼。
進口org.apache.spark.sql.functions。expr瓦爾人= Seq((0,“比爾室”,0,Seq(100)),(1,“馬泰Zaharia”, 1, Seq(500、250、100)),(2,“邁克爾Armbrust”, 1, Seq (250、100))) .toDF (“id”、“名稱”、“graduate_program”,“spark_status”) val graduateProgram = Seq((0,“大師”,“學校的信息”,“加州大學伯克利分校”),(2,“大師”,“電”,“加州大學伯克利分校”),(1,“博士”。“電”,“加州大學伯克利分校”).toDF (“id”、“學位”,“部門”、“學校”)val sparkStatus = Seq((500年,“副總統”),(250年,“PMC成員”),(100年,“貢獻者”)).toDF (“id”,“狀態”)人.withColumnRenamed (“id”、“personId”) . join (sparkStatus, expr (“array_contains (spark_status, id)”)),告訴()
