如何在 Apache-Spark 2.x 中使用 java 执行增量序列

Question

如何在 A​​pache-Spark 2.x 中使用 java 执行 增量序列 数据框 ||临时表 .

换句话说，ApacheSpark 中 monotonically_increasing_id() 函数的等价物是什么->Sql->java || API->Java

Answer 1

使用 Scala：

val dataFrame1 = dataFrame0.withColumn("index",monotonically_increasing_id())

和java

import org.apache.spark.sql.functions;
Daraset<Row> dataFrame1 = dataFrame0.withColumn("index",functions.monotonically_increasing_id());