Package org.apache.iceberg.actions

Class Spark3MigrateAction

  • All Implemented Interfaces:
    Action<CreateAction,​java.lang.Long>, CreateAction
    @Deprecated
public class Spark3MigrateAction
extends java.lang.Object
implements CreateAction
    Deprecated.
    since 0.12.0, will be removed in 0.13.0; use MigrateTable instead.
    Takes a Spark table in the sourceCatalog and attempts to transform it into an Iceberg Table in the same location with the same identifier. Once complete the identifier which previously referred to a non-iceberg table will refer to the newly migrated iceberg table.

    • Constructor Summary

      Constructors 
      Constructor Description
      Spark3MigrateAction​(org.apache.spark.sql.SparkSession spark, org.apache.spark.sql.connector.catalog.CatalogPlugin sourceCatalog, org.apache.spark.sql.connector.catalog.Identifier sourceTableName)
      Deprecated.
       

    • Method Summary

      All Methods Instance Methods Concrete Methods Deprecated Methods 
      Modifier and Type Method Description
      java.lang.Long execute()
      Deprecated.
      Executes this action.
      CreateAction withProperties​(java.util.Map<java.lang.String,​java.lang.String> properties)
      Deprecated.
      Adds additional properties to the newly created Iceberg table.
      CreateAction 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

      • Spark3MigrateAction

        public Spark3MigrateAction​(org.apache.spark.sql.SparkSession spark,
                           org.apache.spark.sql.connector.catalog.CatalogPlugin sourceCatalog,
                           org.apache.spark.sql.connector.catalog.Identifier sourceTableName)
        Deprecated.

    • Method Detail

      • withProperties

        public CreateAction 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 CreateAction 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