Class SparkPositionDeletesRewriteBuilder

  • All Implemented Interfaces:
    org.apache.spark.sql.connector.write.WriteBuilder

    public class SparkPositionDeletesRewriteBuilder
    extends java.lang.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

      All Methods Instance Methods Concrete Methods 
      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 Detail

      • build

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