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
-
Method Summary
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
-
-
Method Details
-
commitStagedChanges
public void commitStagedChanges()- Specified by:
commitStagedChanges
in interfaceorg.apache.spark.sql.connector.catalog.StagedTable
-
abortStagedChanges
public void abortStagedChanges()- Specified by:
abortStagedChanges
in interfaceorg.apache.spark.sql.connector.catalog.StagedTable
-