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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SparkPositionDeletesRewrite.DeleteTaskCommit

Method Summary

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, reportDriverMetrics, supportedCustomMetrics, toStreaming

Method Details

toBatch

public org.apache.spark.sql.connector.write.BatchWrite toBatch()

Specified by:

toBatch in interface org.apache.spark.sql.connector.write.Write