Package org.apache.iceberg.spark.source

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 Summary

Constructors

Constructor	Description
StagedSparkTable(Transaction transaction)

Method Summary

Modifier and Type	Method	Description
void	abortStagedChanges()
void	commitStagedChanges()

Methods inherited from class org.apache.iceberg.spark.source.SparkTable

branch, canDeleteWhere, capabilities, copyWithBranch, copyWithSnapshotId, deleteWhere, equals, hashCode, metadataColumns, name, newRowLevelOperationBuilder, newScanBuilder, newWriteBuilder, partitioning, properties, schema, snapshotId, table, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.spark.sql.connector.catalog.SupportsDeleteV2

truncateTable

Methods inherited from interface org.apache.spark.sql.connector.catalog.SupportsMetadataColumns

canRenameConflictingMetadataColumns

Methods inherited from interface org.apache.spark.sql.connector.catalog.Table

capabilities, columns, name, partitioning, properties, schema

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