public class StagedSparkTable extends SparkTable implements org.apache.spark.sql.connector.catalog.StagedTable
Constructor and Description |
---|
StagedSparkTable(Transaction transaction) |
Modifier and Type | Method and Description |
---|---|
void |
abortStagedChanges() |
void |
commitStagedChanges() |
canDeleteWhere, capabilities, copyWithBranch, copyWithSnapshotId, deleteWhere, equals, hashCode, metadataColumns, name, newRowLevelOperationBuilder, newScanBuilder, newWriteBuilder, partitioning, properties, schema, snapshotId, table, toString
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
public StagedSparkTable(Transaction transaction)
public void commitStagedChanges()
commitStagedChanges
in interface org.apache.spark.sql.connector.catalog.StagedTable
public void abortStagedChanges()
abortStagedChanges
in interface org.apache.spark.sql.connector.catalog.StagedTable