如何添加一個唯一的id列到DataFrame，Apache Spark，Scala

我有一個DataFrame，我想與另一個Dataframe連接，然後按原始行進行分組，但原始行沒有唯一的id。我如何添加一個唯一的ID或以其他方式實現該目標。如何添加一個唯一的id列到DataFrame，Apache Spark，Scala

2017-03-17 qonf

能否請您與列詳細信息添加兩個樣品dataframes？ –

您可以使用monotonically_increasing_id

import org.apache.spark.sql.functions._ 
val unique_df = original_df.withColumn("UniqueID", monotonically_increasing_id)

2017-03-17 09:13:01 Tawkir

我試圖像上面那樣運行它。但我得到：沒有模塊命名monotonically_increasing_id – user3245256

它應該工作。你有沒有使用該導入聲明？你的火花版本又是什麼？ – Tawkir

謝謝。我得到它的工作。這個特別的進口聲明對我不起作用。我必須將其更改爲：從pyspark.sql.functions import monotonically_increasing_id – user3245256

回答