以下代碼片段將細節文件每個分區數
進口com.databricks.sql.transaction.tahoe。DeltaLog org.apache.hadoop.fs進口。路徑val deltaPath = " < table_path > " val deltaLog = deltaLog(火花,新的路徑(deltaPath + / _delta_log)) val currentFiles = deltaLog.snapshot。allFiles顯示(currentFiles.groupBy (partitionValues.col) .count () .orderBy(“計數”.desc)美元)
以下代碼片段將細節文件每個分區數
進口com.databricks.sql.transaction.tahoe。DeltaLog org.apache.hadoop.fs進口。路徑val deltaPath = " < table_path > " val deltaLog = deltaLog(火花,新的路徑(deltaPath + / _delta_log)) val currentFiles = deltaLog.snapshot。allFiles顯示(currentFiles.groupBy (partitionValues.col) .count () .orderBy(“計數”.desc)美元)
你好,
如何安裝這個庫的導入com.databricks.sql.transaction.tahoe。DeltaLog”磚集群?我得到模塊沒有找到錯誤。
TQ操作
BR
Saurabh