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.SupportsDelete, org.apache.spark.sql.connector.catalog.SupportsRead, org.apache.spark.sql.connector.catalog.SupportsWrite, org.apache.spark.sql.connector.catalog.Table

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

capabilities, deleteWhere, equals, hashCode, name, newScanBuilder, newWriteBuilder, partitioning, properties, schema, 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, name, partitioning, properties, schema

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