spark dataFrame withColumn

说明:withColumn用于在原有DF新增一列es6 1. 初始化sqlContextsql val sqlContext = new org.apache.spark.sql.SQLContext(sc) apache 2.导入sqlContext隐式转换json import sqlContext.implicits._ post 3.  建立DataFramesspa   val df =
相关文章
相关标签/搜索