我有一个数据框,其所有列都是字符串类型,并且我有一个包含每列所需类型的架构。有没有一种方法可以将转换插入到一个大的 try/catch 子句中并立即动态地隐藏整个模式?我见过的唯一解决方案是专门处理每一列并转换其类型。
最佳答案
尝试:
val newDf = sparkSession.createDataFrame(oldDf.rdd, schema)
关于java - 立即转换 Spark 数据帧现有架构,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/69790422/