title: “Clone To Paimon” weight: 5 type: docs aliases:

  • /migration/clone.html

Clone To Paimon

Clone supports cloning tables to Paimon tables.

  1. Clone is OVERWRITE semantic that will overwrite the partitions of the target table according to the data.
  2. Clone is reentrant, but it requires existing tables to contain all fields from the source table and have the same partition fields.

Currently, clone supports:

  1. Clone Hive tables in Hive Catalog to Paimon Catalog, supports Parquet, ORC, Avro formats, target table will be append table.
  2. Clone Hudi tables in Hive Catalog to Paimon Catalog, target table will be append table.

The source table below is currently under development:

  1. Clone Paimon tables to Paimon tables, target table can be primary table or append table.
  2. Clone Iceberg tables in Hive Catalog to Paimon Catalog, target table will be append table.

Clone Hive Table

<FLINK_HOME>/flink run ./paimon-flink-action-{{< version >}}.jar \
clone \
--database default \
--table hivetable \
--catalog_conf metastore=hive \
--catalog_conf uri=thrift://localhost:9088 \
--target_database test \
--target_table test_table \
--target_catalog_conf warehouse=my_warehouse \
--parallelism 10 \
--where <filter_spec>

You can use filter spec to specify the filtering condition for the partition.

Clone Hive Database

<FLINK_HOME>/flink run ./paimon-flink-action-{{< version >}}.jar \
clone \
--database default \
--catalog_conf metastore=hive \
--catalog_conf uri=thrift://localhost:9088 \
--target_database test \
--parallelism 10 \
--target_catalog_conf warehouse=my_warehouse
--included_tables <included_tables_spec> \
--excluded_tables <excluded_tables_spec>

“--included_tables” and “--excluded_tables” are optional parameters, which are used to specify the tables that need or don't need to be cloned. The format is <database1>.<table1>,<database2>.<table2>,<database3>.<table3>. “--excluded_tables” has higher priority than “--included_tables” if you specified both.

Clone Hive Catalog

<FLINK_HOME>/flink run ./paimon-flink-action-{{< version >}}.jar \
clone \
--catalog_conf metastore=hive \
--catalog_conf uri=thrift://localhost:9088 \
--parallelism 10 \
--target_catalog_conf warehouse=my_warehouse \
--included_tables <included_tables_spec> \
--excluded_tables <excluded_tables_spec>

“--included_tables” and “--excluded_tables” are optional parameters, which are used to specify the tables that need or don't need to be cloned. The format is <database1>.<table1>,<database2>.<table2>,<database3>.<table3>. “--excluded_tables” has higher priority than “--included_tables” if you specified both.

Clone Hudi Tables

Clone Hudi needs dependency: hudi-flink1.18-bundle-0.15.0.jar

The execution method is the same as the Hive table mentioned above.

Clone Iceberg Tables

Clone Iceberg needs dependency: iceberg-flink-runtime-1.20-1.8.1.jar

The execution method is the same as the Hive table mentioned above.