本节介绍访问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]