Class SparkPositionDeletesRewrite

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

    public class SparkPositionDeletesRewrite
    extends java.lang.Object
    implements org.apache.spark.sql.connector.write.Write
    Write class for rewriting position delete files from Spark. Responsible for creating SparkPositionDeletesRewrite.PositionDeleteBatchWrite

    This class is meant to be used for an action to rewrite position delete files. Hence, it assumes all position deletes to rewrite have come from ScanTaskSetManager and that all have the same partition spec id and partition values.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.spark.sql.connector.write.BatchWrite toBatch()  
      • 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.Write

        description, supportedCustomMetrics, toStreaming
    • Method Detail

      • toBatch

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