Package io.delta.kernel.internal

Class TableChangesUtils

Object

io.delta.kernel.internal.TableChangesUtils

public class TableChangesUtils
extends Object

Utility class for table changes operations.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	TIMESTAMP_COLUMN_NAME	Column name for the timestamp metadata column added to getActions results.
static final String	VERSION_COLUMN_NAME	Column name for the version metadata column added to getActions results.

Method Summary

Modifier and Type	Method	Description
static ColumnarBatch	addVersionAndTimestampColumns(Engine engine, ColumnarBatch batch, long version, long timestamp)	Adds version and timestamp columns to a columnar batch.
static CloseableIterator<ColumnarBatch>	flattenCommitsAndAddMetadata(Engine engine, CloseableIterator<CommitActions> commits)	Flattens an iterator of CommitActions into an iterator of ColumnarBatch, adding version and timestamp columns to each batch.

Methods inherited from class java.lang.Object

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

Field Details

VERSION_COLUMN_NAME

public static final String VERSION_COLUMN_NAME

Column name for the version metadata column added to getActions results.

See Also:

• Constant Field Values

TIMESTAMP_COLUMN_NAME

public static final String TIMESTAMP_COLUMN_NAME

Column name for the timestamp metadata column added to getActions results.

See Also:

• Constant Field Values

Method Details

addVersionAndTimestampColumns

public static ColumnarBatch addVersionAndTimestampColumns(Engine engine,
 ColumnarBatch batch,
 long version,
 long timestamp)

Adds version and timestamp columns to a columnar batch.

The version and timestamp columns are added as the first two columns in the batch.

Parameters:

engine - the engine for expression evaluation

batch - the original batch

version - the version value to add

timestamp - the timestamp value to add

Returns:

a new batch with version and timestamp columns prepended

flattenCommitsAndAddMetadata

public static CloseableIterator<ColumnarBatch> flattenCommitsAndAddMetadata(Engine engine,
 CloseableIterator<CommitActions> commits)

Flattens an iterator of CommitActions into an iterator of ColumnarBatch, adding version and timestamp columns to each batch.

Parameters:

engine - the engine for expression evaluation

commits - the iterator of CommitActions to flatten

Returns:

an iterator of ColumnarBatch with version and timestamp columns added