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 and Description
StagedSparkTable(Transaction transaction)

Method Summary

Modifier and Type	Method and 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.Table

capabilities, columns, name, partitioning, properties, schema

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

truncateTable

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

canRenameConflictingMetadataColumns

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