DeltaHistoryManager

= DeltaHistoryManager

DeltaHistoryManager is...FIXME

== [[getHistory]] getHistory Method

[source, scala]¶

getHistory( limitOpt: Option[Int]): Seq[CommitInfo] getHistory( start: Long, end: Option[Long]): Seq[CommitInfo]

getHistory...FIXME

NOTE: getHistory is used when...FIXME

== [[getActiveCommitAtTime]] getActiveCommitAtTime Method

[source, scala]¶

getActiveCommitAtTime( timestamp: Timestamp, canReturnLastCommit: Boolean, mustBeRecreatable: Boolean = true): Commit

getActiveCommitAtTime...FIXME

NOTE: getActiveCommitAtTime is used exclusively when DeltaTableUtils utility is requested to <>.

== [[checkVersionExists]] checkVersionExists Method

[source, scala]¶

checkVersionExists(version: Long): Unit¶

checkVersionExists...FIXME

NOTE: checkVersionExists is used when...FIXME

== [[parallelSearch]] parallelSearch Internal Method

[source, scala]¶

parallelSearch( time: Long, start: Long, end: Long): Commit

parallelSearch...FIXME

NOTE: parallelSearch is used exclusively when DeltaHistoryManager is requested to <>.

== [[parallelSearch0]] parallelSearch0 Internal Utility

[source, scala]¶

parallelSearch0( spark: SparkSession, conf: SerializableConfiguration, logPath: String, time: Long, start: Long, end: Long, step: Long): Commit

parallelSearch0...FIXME

NOTE: parallelSearch0 is used exclusively when DeltaHistoryManager is requested to <>.

== [[getCommitInfo]] CommitInfo Of Delta File -- getCommitInfo Internal Utility

[source, scala]¶

getCommitInfo( logStore: LogStore, basePath: Path, version: Long): CommitInfo

getCommitInfo...FIXME

NOTE: getCommitInfo is used when...FIXME