Class StagedSparkTable

java.lang.Object
org.apache.iceberg.spark.source.SparkTable
org.apache.iceberg.spark.source.StagedSparkTable
All Implemented Interfaces:
org.apache.spark.sql.connector.catalog.StagedTable, org.apache.spark.sql.connector.catalog.SupportsDeleteV2, org.apache.spark.sql.connector.catalog.SupportsMetadataColumns, org.apache.spark.sql.connector.catalog.SupportsRead, org.apache.spark.sql.connector.catalog.SupportsRowLevelOperations, org.apache.spark.sql.connector.catalog.SupportsWrite, org.apache.spark.sql.connector.catalog.Table, org.apache.spark.sql.connector.catalog.TruncatableTable

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

    • StagedSparkTable

      public StagedSparkTable(Transaction transaction)
  • Method Details

    • 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