磚

嗨@Aditya Deshpande沒有鎖定機製PK的三角洲。您可以使用df row_number()函數和節約使用寫前三角洲和做不同的()。

嗨@pascalvanbellen,沒有一顆的概念,PK, SK火花。但是磚δ自動照顧SCD類型的場景。https://docs.www.eheci.com/spark/latest/spark-sql/language-manual/merge-into.html slowly-changing-data-scd-type-2……

@karthik。我試著thisdf.write.option(“壓縮”,“沒有一個”).mode .save(“覆蓋”)(“testoutput.parquet”)

@Nithin Tiruveedhi請嚐試如下。下麵是一個例子的單詞計數邏輯。val tmpTable1 = sqlContext。sql(“選擇row_number()(按計數)rnk,詞,從wordcount數”)tmpTable1.registertempTable (“wordcount_rownum”) sqlContext.ca……