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)

    + +