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.