Package org.apache.iceberg.actions

Class Spark3SnapshotAction

  • All Implemented Interfaces:
    Action<CreateAction,​java.lang.Long>, CreateAction, SnapshotAction
    @Deprecated
public class Spark3SnapshotAction
extends java.lang.Object
implements SnapshotAction
    Deprecated.
    since 0.12.0, will be removed in 0.13.0; use SnapshotTable instead.
    Creates a new Iceberg table based on a source Spark table. The new Iceberg table will have a different data and metadata directory allowing it to exist independently of the source table.

    • Constructor Summary

      Constructors 
      Constructor Description
      Spark3SnapshotAction​(org.apache.spark.sql.SparkSession spark, org.apache.spark.sql.connector.catalog.CatalogPlugin sourceCatalog, org.apache.spark.sql.connector.catalog.Identifier sourceTableIdent, org.apache.spark.sql.connector.catalog.CatalogPlugin destCatalog, org.apache.spark.sql.connector.catalog.Identifier destTableIdent)
      Deprecated.
       

    • Method Summary

      All Methods Instance Methods Concrete Methods Deprecated Methods 
      Modifier and Type Method Description
      java.lang.Long execute()
      Deprecated.
      Executes this action.
      SnapshotAction withLocation​(java.lang.String location)
      Deprecated.
       
      SnapshotAction withProperties​(java.util.Map<java.lang.String,​java.lang.String> properties)
      Deprecated.
      Adds additional properties to the newly created Iceberg table.
      SnapshotAction withProperty​(java.lang.String key, java.lang.String value)
      Deprecated.
      Adds an additional property to the newly created Iceberg table.

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • Spark3SnapshotAction

        public Spark3SnapshotAction​(org.apache.spark.sql.SparkSession spark,
                            org.apache.spark.sql.connector.catalog.CatalogPlugin sourceCatalog,
                            org.apache.spark.sql.connector.catalog.Identifier sourceTableIdent,
                            org.apache.spark.sql.connector.catalog.CatalogPlugin destCatalog,
                            org.apache.spark.sql.connector.catalog.Identifier destTableIdent)
        Deprecated.

    • Method Detail

      • withProperties

        public SnapshotAction withProperties​(java.util.Map<java.lang.String,​java.lang.String> properties)
        Deprecated.
        Description copied from interface: CreateAction
        Adds additional properties to the newly created Iceberg table. Any properties with the same key name will be overwritten.
        Specified by:
        withProperties in interface CreateAction
        Parameters:
        properties - a map of properties to be included
        Returns:
        this for chaining

      • withProperty

        public SnapshotAction withProperty​(java.lang.String key,
                                   java.lang.String value)
        Deprecated.
        Description copied from interface: CreateAction
        Adds an additional property to the newly created Iceberg table. Any properties with the same key name will be overwritten.
        Specified by:
        withProperty in interface CreateAction
        Parameters:
        key - the key of the property to add
        value - the value of the property to add
        Returns:
        this for chaining

      • execute

        public java.lang.Long execute()
        Deprecated.
        Description copied from interface: Action
        Executes this action.
        Specified by:
        execute in interface Action<CreateAction,​java.lang.Long>
        Returns:
        the result of this action