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

>>阅读原文<<