DeltaHistoryManager¶
DeltaHistoryManager
is used for version and commit history of a delta table.
Creating Instance¶
DeltaHistoryManager
takes the following to be created:
- DeltaLog
- Maximum number of keys (default:
1000
)
DeltaHistoryManager
is created when:
DeltaLog
is requested for oneDeltaTableOperations
is requested to execute history command
Version and Commit History¶
getHistory(
start: Long,
end: Option[Long] = None): Seq[CommitInfo]
getHistory(
limitOpt: Option[Int]): Seq[CommitInfo]
getHistory
...FIXME
getHistory
is used when:
DeltaTableOperations
is requested to executeHistory (for DeltaTable.history operator)- DescribeDeltaHistoryCommand is executed (for DESCRIBE HISTORY SQL command)
getCommitInfo Utility¶
getCommitInfo(
logStore: LogStore,
basePath: Path,
version: Long): CommitInfo
getCommitInfo
...FIXME
getActiveCommitAtTime¶
getActiveCommitAtTime(
timestamp: Timestamp,
canReturnLastCommit: Boolean,
mustBeRecreatable: Boolean = true,
canReturnEarliestCommit: Boolean = false): Commit
getActiveCommitAtTime
...FIXME
getActiveCommitAtTime
is used when:
DeltaTableUtils
utility is used to resolveTimeTravelVersionDeltaSource
is requested for getStartingVersion