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.WriteWriteclass for rewriting position delete files from Spark. Responsible for creatingSparkPositionDeletesRewrite.PositionDeleteBatchWriteThis 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
ScanTaskSetManagerand that all have the same partition spec id and partition values.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classSparkPositionDeletesRewrite.DeleteTaskCommit
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.spark.sql.connector.write.BatchWritetoBatch()
-