【发布时间】:2017-01-12 10:25:37
【问题描述】:
我想将datframe 中的列列表插入到列表[列] 中,以便执行选择请求。这意味着想要获取列列表并将其自动插入列表 [column] 任何帮助谢谢
object PCA extends App{
val spark = SparkSession.builder.master("local").appName("my-spark-app").getOrCreate()
val strPath="C:/Users/mhattabi/Desktop/testBis2.txt"
val intial_Data=spark.read.option("header",true).csv(strPath)
//array string contains names of column
val arrayList=intial_Data.columns
var colsList = List[Column]()
//wanna insert name of column into the listColum
arrayList.foreach(p=>colsList.)
//i want to have something like
//val colsList = List(col("col1"),col("col2"))
//intial_Data.select(colsList:_*).show
}
【问题讨论】:
标签: scala apache-spark apache-spark-sql