Package org.apache.drill.metastore.iceberg.operate

Class IcebergModify<T>

java.lang.Object

org.apache.drill.metastore.operate.AbstractModify<T>

org.apache.drill.metastore.iceberg.operate.IcebergModify<T>

Type Parameters:

T - Metastore component unit type

All Implemented Interfaces:

Modify<T>

public class IcebergModify<T>
extends AbstractModify<T>

Implementation of Modify interface based on AbstractModify parent class. Modifies information in Iceberg table based on given overwrite or delete operations. Executes given operations in one transaction.

Constructor Summary

Constructors

Constructor	Description
IcebergModify(MetadataTypeValidator metadataTypeValidator, IcebergMetastoreContext<T> context)

Method Summary

Modifier and Type	Method	Description
protected void	addDelete(Delete delete)	Adds delete operation to the list of pending operations.
protected void	addOverwrite(List<T> units)	Adds overwrite operation to the list of pending operations.
void	execute()	Executes list of provided metastore operations in one transaction if Metastore implementation supports transactions, otherwise executes operations consecutively.
void	purge()	Deletes all data from the Metastore component.

Methods inherited from class org.apache.drill.metastore.operate.AbstractModify

delete, overwrite

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.drill.metastore.operate.Modify

overwrite

Constructor Details

IcebergModify

public IcebergModify(MetadataTypeValidator metadataTypeValidator,
 IcebergMetastoreContext<T> context)

Method Details

execute

public void execute()

Description copied from interface: Modify

Executes list of provided metastore operations in one transaction if Metastore implementation supports transactions, otherwise executes operations consecutively. All operations should be executed in the same order as they were added.

purge

public void purge()

Description copied from interface: Modify

Deletes all data from the Metastore component. Note, this is terminal operation and it does not take into account any previously set delete operations or overwrite units, it just deletes all data.

addOverwrite

protected void addOverwrite(List<T> units)

Description copied from class: AbstractModify

Adds overwrite operation to the list of pending operations. Is used to ensure operations execution order.

Specified by:

addOverwrite in class AbstractModify<T>

Parameters:

units - list of Metastore metadata units

addDelete

protected void addDelete(Delete delete)

Description copied from class: AbstractModify

Adds delete operation to the list of pending operations. Is used to ensure operations execution order.

Specified by:

addDelete in class AbstractModify<T>

Parameters:

delete - Metastore delete operation holder