使用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 ...