From 7a9eb8102370a708c0b2d4934ea66a478182c9b0 Mon Sep 17 00:00:00 2001 From: yangjf2019 Date: Thu, 13 Feb 2025 15:44:55 +0800 Subject: [PATCH] =?UTF-8?q?[doc]=20Add=20missing=20documentation=20for=20t?= =?UTF-8?q?he=20=E2=80=98migrate=5Ficeberg=5Ftable=E2=80=99=20command?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- docs/content/flink/procedures.md | 33 ++++++++++++++++++++++++++++++-- 1 file changed, 31 insertions(+), 2 deletions(-) diff --git a/docs/content/flink/procedures.md b/docs/content/flink/procedures.md index 67a4290fb9bc..0096bbabe04b 100644 --- a/docs/content/flink/procedures.md +++ b/docs/content/flink/procedures.md @@ -658,7 +658,7 @@ All available procedures are listed below. refresh_object_table - CALL sys.refresh_object_table('identifier') + CALL [catalog.]sys.refresh_object_table('identifier') To refresh_object_table a object table. Arguments: @@ -671,7 +671,7 @@ All available procedures are listed below. compact_manifest - CALL sys.compact_manifest(`table` => 'identifier') + CALL [catalog.]sys.compact_manifest(`table` => 'identifier') To compact_manifest the manifests. Arguments: @@ -681,5 +681,34 @@ All available procedures are listed below. CALL sys.compact_manifest(`table` => 'default.T') + + migrate_iceberg_table + + -- Use named argument
+ CALL [catalog.]sys.migrate_iceberg_table(
+ `source_table` => 'identifier',
+ `iceberg_options` => 'iceberg options',
+ `options` =>'table options',
+ `parallelism` => 'the parallelism of migrate process')

+ -- Use indexed argument
+ CALL [catalog.]sys.migrate_iceberg_table('source_table')

+ CALL [catalog.]sys.migrate_iceberg_table('source_table', 'iceberg_options')

+ CALL [catalog.]sys.migrate_iceberg_table('source_table', 'iceberg_options', 'options')

+ CALL [catalog.]sys.migrate_iceberg_table('source_table', 'iceberg_options', 'options', 'parallelism')

+ + + To migrate_iceberg_table iceberg table to paimon table. Arguments: +
  • source_table(required): name of the origin table to migrate. Cannot be empty.
  • +
  • iceberg_options(optional): the table options of the iceberg table to migrate.
  • +
  • options(optional): the core options.See its document for a complete list of configurations.
  • +
  • parallelism(optional): number of parallelisms to migrate iceberg tables.
  • + + + -- for hive-catalog

    + CALL sys.migrate_iceberg_table(`source_table` => 'default.T', `iceberg_options` => 'metadata.iceberg.storage=hive-catalog,metadata.iceberg.uri=thrift://localhost:9083', `options` => 'file.format=parquet', `parallelism` => 5)

    + -- for hadoop-catalog

    + CALL sys.migrate_iceberg_table(`source_table` => 'default.T', `iceberg_options` => 'metadata.iceberg.storage=hadoop-catalog,iceberg_warehouse=hdfs:///path/to/iceberg/warehouse', `options` => 'file.format=parquet', `parallelism` => 5)

    + +