Package org.apache.iceberg.spark.source
Class SparkPositionDeletesRewrite
- java.lang.Object
-
- org.apache.iceberg.spark.source.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 creatingSparkPositionDeletesRewrite.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.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
SparkPositionDeletesRewrite.DeleteTaskCommit
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.spark.sql.connector.write.BatchWrite
toBatch()
-