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 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

Modifier and Type	Method and 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