Class StagedSparkTable

  • All Implemented Interfaces:
    org.apache.spark.sql.connector.catalog.StagedTable, org.apache.spark.sql.connector.catalog.SupportsDelete, org.apache.spark.sql.connector.catalog.SupportsRead, org.apache.spark.sql.connector.catalog.SupportsWrite, org.apache.spark.sql.connector.catalog.Table, ExtendedSupportsDelete, SupportsMerge

    public class StagedSparkTable
    extends SparkTable
    implements org.apache.spark.sql.connector.catalog.StagedTable
    • Constructor Detail

      • StagedSparkTable

        public StagedSparkTable​(Transaction transaction)
    • Method Detail

      • commitStagedChanges

        public void commitStagedChanges()
        Specified by:
        commitStagedChanges in interface org.apache.spark.sql.connector.catalog.StagedTable
      • abortStagedChanges

        public void abortStagedChanges()
        Specified by:
        abortStagedChanges in interface org.apache.spark.sql.connector.catalog.StagedTable