Package 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
    Description
    Overwrite(org.apache.iceberg.DataFile dataFile, org.apache.iceberg.expressions.Expression filter)
     

  • Method Summary

    Modifier and Type
    Method
    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 Details

    • Overwrite

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

  • Method Details

    • 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