Package org.apache.iceberg.spark.source

Class SparkPositionDeletesRewriteBuilder

java.lang.Object
org.apache.iceberg.spark.source.SparkPositionDeletesRewriteBuilder
All Implemented Interfaces:
org.apache.spark.sql.connector.write.WriteBuilder
public class SparkPositionDeletesRewriteBuilder extends Object implements org.apache.spark.sql.connector.write.WriteBuilder
Builder class for rewrites of position delete files from Spark. Responsible for creating SparkPositionDeletesRewrite.

This class is meant to be used for an action to rewrite delete files. Hence, it makes an assumption that all incoming deletes belong to the same partition, and that incoming dataset is from ScanTaskSetManager.

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.spark.sql.connector.write.Write
    build()
     

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.apache.spark.sql.connector.write.WriteBuilder

    buildForBatch, buildForStreaming

  • Method Details

    • build

      public org.apache.spark.sql.connector.write.Write build()
      Specified by:
      build in interface org.apache.spark.sql.connector.write.WriteBuilder