org.apache.spark.sql.connector.iceberg.write

Interface SupportsDelta

All Superinterfaces:

org.apache.spark.sql.connector.write.RowLevelOperation

public interface SupportsDelta
extends org.apache.spark.sql.connector.write.RowLevelOperation

A mix-in interface for RowLevelOperation. Data sources can implement this interface to indicate they support handling deltas of rows.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.spark.sql.connector.write.RowLevelOperation

org.apache.spark.sql.connector.write.RowLevelOperation.Command

Method Summary

Modifier and Type	Method and Description
DeltaWriteBuilder	newWriteBuilder(org.apache.spark.sql.connector.write.LogicalWriteInfo info)
org.apache.spark.sql.connector.expressions.NamedReference[]	rowId() Returns the row ID column references that should be used for row equality.

Methods inherited from interface org.apache.spark.sql.connector.write.RowLevelOperation

command, description, newScanBuilder, requiredMetadataAttributes

Method Detail

newWriteBuilder

DeltaWriteBuilder newWriteBuilder(org.apache.spark.sql.connector.write.LogicalWriteInfo info)

Specified by:

newWriteBuilder in interface org.apache.spark.sql.connector.write.RowLevelOperation

rowId

org.apache.spark.sql.connector.expressions.NamedReference[] rowId()

Returns the row ID column references that should be used for row equality.