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.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method 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.
-
-
-
Method Detail
-
newWriteBuilder
DeltaWriteBuilder newWriteBuilder(org.apache.spark.sql.connector.write.LogicalWriteInfo info)
- Specified by:
newWriteBuilder
in interfaceorg.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.
-
-