Package 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

      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.

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