org.apache.drill.metastore.iceberg.operate

Class Overwrite

java.lang.Object

org.apache.drill.metastore.iceberg.operate.Overwrite

All Implemented Interfaces:

IcebergOperation

public class Overwrite
extends Object
implements IcebergOperation

Iceberg overwrite operation: overwrites data with given data file based on given row filter.

Constructor Summary

Constructors

Constructor and Description
Overwrite(org.apache.iceberg.DataFile dataFile, org.apache.iceberg.expressions.Expression filter)

Method Summary

Modifier and Type	Method and Description
void	add(org.apache.iceberg.Transaction transaction) Adds operation to the given transaction.
org.apache.iceberg.DataFile	dataFile()
org.apache.iceberg.expressions.Expression	filter()

Methods inherited from class java.lang.Object

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

Constructor Detail

Overwrite

public Overwrite(org.apache.iceberg.DataFile dataFile,
                 org.apache.iceberg.expressions.Expression filter)

Method Detail

filter

public org.apache.iceberg.expressions.Expression filter()

dataFile

public org.apache.iceberg.DataFile dataFile()

add

public void add(org.apache.iceberg.Transaction transaction)

Description copied from interface: IcebergOperation

Adds operation to the given transaction.

Specified by:

add in interface IcebergOperation

Parameters:

transaction - current transaction