使用zipwithindex 算子給dataframe增加自增列 row_number函數實現自增,udf函數實現自增
DataFrame df = ...StructType schema = df.schema().add(DataTypes.createStructField("id", DataTypes.Lo ...
DataFrame df = ...StructType schema = df.schema().add(DataTypes.createStructField("id", DataTypes.Lo ...