Spark 修改整列數據類型+寫入數據到HDFS

Spark 修改dataset整列數據類型web import org.apache.spark.sql.types.IntegerType geoans.select(geoans.col("pointNum").cast(IntegerType).as("lat")) 寫入數據到HDFSsql a.repartition(3).write.parquet("hdfs://master:900

>>阅读原文<<