Package io.delta.kernel.internal.files

Class LogDataUtils

Object

io.delta.kernel.internal.files.LogDataUtils

public final class LogDataUtils
extends Object

Method Summary

Modifier and Type	Method	Description
static List<ParsedDeltaData>	combinePublishedAndRatifiedDeltasWithCatalogPriority(List<ParsedDeltaData> publishedDeltas, List<ParsedDeltaData> ratifiedDeltas)	Combines a list of published Deltas and ratified Deltas into a single list of Deltas such that there is exactly one ParsedDeltaData per version.
static void	validateLogDataContainsOnlyRatifiedStagedCommits(List<? extends ParsedLogData> logDatas)
static void	validateLogDataIsSortedContiguous(List<? extends ParsedLogData> logDatas)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

validateLogDataContainsOnlyRatifiedStagedCommits

public static void validateLogDataContainsOnlyRatifiedStagedCommits(List<? extends ParsedLogData> logDatas)

validateLogDataIsSortedContiguous

public static void validateLogDataIsSortedContiguous(List<? extends ParsedLogData> logDatas)

combinePublishedAndRatifiedDeltasWithCatalogPriority

public static List<ParsedDeltaData> combinePublishedAndRatifiedDeltasWithCatalogPriority(List<ParsedDeltaData> publishedDeltas,
 List<ParsedDeltaData> ratifiedDeltas)

Combines a list of published Deltas and ratified Deltas into a single list of Deltas such that there is exactly one ParsedDeltaData per version. When there is both a published Delta and a ratified staged Delta for the same version, prioritizes the ratified Delta.

The method requires but does not validate the following:

• publishedDeltas are sorted and contiguous
• ratifiedDeltas are sorted and contiguous
• the commit versions present in publishedDeltas and ratifiedDeltas, when combined, reflect a contiguous version range. In other words, if the two do not overlap, publishedDeltas.last = ratifiedDeltas.first + 1).