Skip to content

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


Last update: 2020-09-24