Package io.delta.kernel.internal.replay
package io.delta.kernel.internal.replay
-
ClassDescriptionThis class takes as input a list of delta files (.json, .checkpoint.parquet) and produces an iterator of (ColumnarBatch, isFromCheckpoint) tuples, where the schema of the ColumnarBatch semantically represents actions (or, a subset of action fields) parsed from the Delta Log.Internal wrapper class holding information needed to perform log replay.This class takes an iterator of (
ColumnarBatch, isFromCheckpoint), where the columnar data inside the columnar batch represents has top level columns "add" and "remove", and produces an iterator ofFilteredColumnarBatchwith only the "add" column and with a selection vector indicating which AddFiles are still active in the table (have not been tombstoned).Class containing the conflict resolution logic when writing to a Delta table.Class containing the rebase state from winning transactions that the current transaction needs to rebase against before attempting the commit.Replays a history of actions from the transaction log to reconstruct the checkpoint state of the table.Internal wrapper class holding information needed to perform log replay.Replays a history of actions, resolving them to produce the current state of the table.Page Token Class for Pagination SupportImplementation ofPaginatedScanFilesIteratorPaginationContextcarries pagination-related information.Static utility class for loading Protocol and Metadata from Delta log files.Result of loading Protocol and Metadata from a LogSegment.