Interface SupportsDelta
-
- All Superinterfaces:
RowLevelOperation
public interface SupportsDelta extends 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.iceberg.write.RowLevelOperation
RowLevelOperation.Command
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description DeltaWriteBuilder
newWriteBuilder(ExtendedLogicalWriteInfo info)
Returns a write builder to configure a write for this row-level operation.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.iceberg.write.RowLevelOperation
command, description, newScanBuilder, requiredMetadataAttributes
-
-
-
-
Method Detail
-
newWriteBuilder
DeltaWriteBuilder newWriteBuilder(ExtendedLogicalWriteInfo info)
Description copied from interface:RowLevelOperation
Returns a write builder to configure a write for this row-level operation.Note that Spark will first configure the scan and then the write, allowing data sources to pass information from the scan to the write. For example, the scan can report which condition was used to read the data that may be needed by the write under certain isolation levels.
- Specified by:
newWriteBuilder
in interfaceRowLevelOperation
-
rowId
org.apache.spark.sql.connector.expressions.NamedReference[] rowId()
Returns the row ID column references that should be used for row equality.
-
-