spark dataframe检查是否存在某列

刘超 4天前 ⋅ 26 阅读   编辑

方法一

if (!baseDF.columns.contains("advIndustry")){
    baseDF = baseDF.withColumn("advIndustry", lit(null).cast("string"))
  }
// lit(null).cast(StringType) or lit(null).cast("string")

注意:本文归作者所有,未经作者允许,不得转载

全部评论: 0

    我有话说: