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 java.lang.Object implements org.apache.spark.sql.connector.write.WriteBuilder
Builder class for rewrites of position delete files from Spark. Responsible for creatingSparkPositionDeletesRewrite
.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()
-