本文介绍如何以Scala或SQL方式访问Delta表的历史信息。

  • Scala
    import io.delta.tables._
    
    val deltaTable = DeltaTable.forPath(spark, pathToTable)
    
    val fullHistoryDF = deltaTable.history()    // 获取table的全部历史。
    val lastOperationDF = deltaTable.history(1) // 获取最近一个版本历史。
  • SQL
    DESCRIBE HISTORY table [LIMIT 1]