This is an automated email from the ASF dual-hosted git repository.
yuzelin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 6f5c8fdbc5 [cdc] Add line breaks to cdc action help message to improve
readability (#5032)
6f5c8fdbc5 is described below
commit 6f5c8fdbc5497abd7ad2ae4b3ce6c442f23cfe6b
Author: yangjf2019 <[email protected]>
AuthorDate: Tue Feb 11 12:07:07 2025 +0800
[cdc] Add line breaks to cdc action help message to improve readability
(#5032)
---
.../cdc/kafka/KafkaSyncDatabaseActionFactory.java | 18 ++++++++-------
.../cdc/kafka/KafkaSyncTableActionFactory.java | 18 ++++++++-------
.../mongodb/MongoDBSyncDatabaseActionFactory.java | 16 +++++++------
.../cdc/mongodb/MongoDBSyncTableActionFactory.java | 14 +++++++-----
.../cdc/mysql/MySqlSyncDatabaseActionFactory.java | 26 ++++++++++++----------
.../cdc/mysql/MySqlSyncTableActionFactory.java | 20 +++++++++--------
.../postgres/PostgresSyncTableActionFactory.java | 21 ++++++++---------
.../pulsar/PulsarSyncDatabaseActionFactory.java | 18 ++++++++-------
.../cdc/pulsar/PulsarSyncTableActionFactory.java | 18 ++++++++-------
9 files changed, 93 insertions(+), 76 deletions(-)
diff --git
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java
index 4c0a14854d..eb3332c731 100644
---
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java
+++
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java
@@ -54,14 +54,16 @@ public class KafkaSyncDatabaseActionFactory
System.out.println("Syntax:");
System.out.println(
- " kafka_sync_database --warehouse <warehouse_path> --database
<database_name> "
- + "[--table_prefix <paimon_table_prefix>] "
- + "[--table_suffix <paimon_table_suffix>] "
- + "[--including_tables <table_name|name_regular_expr>]
"
- + "[--excluding_tables <table_name|name_regular_expr>]
"
- + "[--type_mapping <option1,option2...>] "
- + "[--kafka_conf <kafka_source_conf> [--kafka_conf
<kafka_source_conf> ...]] "
- + "[--catalog_conf <paimon_catalog_conf>
[--catalog_conf <paimon_catalog_conf> ...]] "
+ " kafka_sync_database \\\n"
+ + "--warehouse <warehouse_path> \\\n"
+ + "--database <database_name> \\\n"
+ + "[--table_prefix <paimon_table_prefix>] \\\n"
+ + "[--table_suffix <paimon_table_suffix>] \\\n"
+ + "[--including_tables <table_name|name_regular_expr>]
\\\n"
+ + "[--excluding_tables <table_name|name_regular_expr>]
\\\n"
+ + "[--type_mapping <option1,option2...>] \\\n"
+ + "[--kafka_conf <kafka_source_conf> [--kafka_conf
<kafka_source_conf> ...]] \\\n"
+ + "[--catalog_conf <paimon_catalog_conf>
[--catalog_conf <paimon_catalog_conf> ...]] \\\n"
+ "[--table_conf <paimon_table_sink_conf>
[--table_conf <paimon_table_sink_conf> ...]]");
System.out.println();
diff --git
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableActionFactory.java
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableActionFactory.java
index 530e4af7c3..59976c9abb 100644
---
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableActionFactory.java
+++
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableActionFactory.java
@@ -52,14 +52,16 @@ public class KafkaSyncTableActionFactory extends
SyncTableActionFactoryBase {
System.out.println("Syntax:");
System.out.println(
- " kafka_sync_table --warehouse <warehouse_path> --database
<database_name> "
- + "--table <table_name> "
- + "[--partition_keys <partition_keys>] "
- + "[--primary_keys <primary_keys>] "
- + "[--type_mapping <option1,option2...>] "
- + "[--computed_column <'column_name=expr_name(args[,
...])'> [--computed_column ...]] "
- + "[--kafka_conf <kafka_source_conf> [--kafka_conf
<kafka_source_conf> ...]] "
- + "[--catalog_conf <paimon_catalog_conf>
[--catalog_conf <paimon_catalog_conf> ...]] "
+ " kafka_sync_table \\\n"
+ + "--warehouse <warehouse_path> \\\n"
+ + "--database <database_name> \\\n"
+ + "--table <table_name> \\\n"
+ + "[--partition_keys <partition_keys>] \\\n"
+ + "[--primary_keys <primary_keys>] \\\n"
+ + "[--type_mapping <option1,option2...>] \\\n"
+ + "[--computed_column <'column_name=expr_name(args[,
...])'> [--computed_column ...]] \\\n"
+ + "[--kafka_conf <kafka_source_conf> [--kafka_conf
<kafka_source_conf> ...]] \\\n"
+ + "[--catalog_conf <paimon_catalog_conf>
[--catalog_conf <paimon_catalog_conf> ...]] \\\n"
+ "[--table_conf <paimon_table_sink_conf>
[--table_conf <paimon_table_sink_conf> ...]]");
System.out.println();
diff --git
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSyncDatabaseActionFactory.java
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSyncDatabaseActionFactory.java
index 6262720de3..3811fd31ee 100644
---
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSyncDatabaseActionFactory.java
+++
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSyncDatabaseActionFactory.java
@@ -55,13 +55,15 @@ public class MongoDBSyncDatabaseActionFactory
System.out.println("Syntax:");
System.out.println(
- " mongodb_sync_database --warehouse <warehouse_path>
--database <database_name> "
- + "[--table_prefix <paimon_table_prefix>] "
- + "[--table_suffix <paimon_table_suffix>] "
- + "[--including_tables
<mongodb_table_name|name_regular_expr>] "
- + "[--excluding_tables
<mongodb_table_name|name_regular_expr>] "
- + "[--mongodb_conf <mongodb_cdc_source_conf>
[--mongodb_conf <mongodb_cdc_source_conf> ...]] "
- + "[--catalog_conf <paimon_catalog_conf>
[--catalog_conf <paimon_catalog_conf> ...]] "
+ " mongodb_sync_database \\\n"
+ + "--warehouse <warehouse_path> \\\n"
+ + "--database <database_name> \\\n"
+ + "[--table_prefix <paimon_table_prefix>] \\\n"
+ + "[--table_suffix <paimon_table_suffix>] \\\n"
+ + "[--including_tables
<mongodb_table_name|name_regular_expr>] \\\n"
+ + "[--excluding_tables
<mongodb_table_name|name_regular_expr>] \\\n"
+ + "[--mongodb_conf <mongodb_cdc_source_conf>
[--mongodb_conf <mongodb_cdc_source_conf> ...]] \\\n"
+ + "[--catalog_conf <paimon_catalog_conf>
[--catalog_conf <paimon_catalog_conf> ...]] \\\n"
+ "[--table_conf <paimon_table_sink_conf>
[--table_conf <paimon_table_sink_conf> ...]]");
System.out.println();
diff --git
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSyncTableActionFactory.java
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSyncTableActionFactory.java
index 38170d6c66..8c7d4c38d2 100644
---
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSyncTableActionFactory.java
+++
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSyncTableActionFactory.java
@@ -70,12 +70,14 @@ public class MongoDBSyncTableActionFactory extends
SyncTableActionFactoryBase {
System.out.println("Syntax:");
System.out.println(
- " mongodb_sync_table --warehouse <warehouse_path> --database
<database_name> "
- + "--table <table_name> "
- + "[--partition_keys <partition_keys>] "
- + "[--computed_column <'column_name=expr_name(args[,
...])'> [--computed_column ...]] "
- + "[--mongodb_conf <mongodb_cdc_source_conf>
[--mongodb_conf <mongodb_cdc_source_conf> ...]] "
- + "[--catalog_conf <paimon_catalog_conf>
[--catalog_conf <paimon_catalog_conf> ...]] "
+ " mongodb_sync_table \\\n"
+ + "--warehouse <warehouse_path> \\\n"
+ + "--database <database_name> \\\n"
+ + "--table <table_name> \\\n"
+ + "[--partition_keys <partition_keys>] \\\n"
+ + "[--computed_column <'column_name=expr_name(args[,
...])'> [--computed_column ...]] \\\n"
+ + "[--mongodb_conf <mongodb_cdc_source_conf>
[--mongodb_conf <mongodb_cdc_source_conf> ...]] \\\n"
+ + "[--catalog_conf <paimon_catalog_conf>
[--catalog_conf <paimon_catalog_conf> ...]] \\\n"
+ "[--table_conf <paimon_table_sink_conf>
[--table_conf <paimon_table_sink_conf> ...]]");
System.out.println();
diff --git
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionFactory.java
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionFactory.java
index 74d0b6f234..93e25b004c 100644
---
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionFactory.java
+++
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionFactory.java
@@ -76,18 +76,20 @@ public class MySqlSyncDatabaseActionFactory
System.out.println("Syntax:");
System.out.println(
- " mysql_sync_database --warehouse <warehouse_path> --database
<database_name> "
- + "[--ignore_incompatible <true/false>] "
- + "[--merge_shards <true/false>] "
- + "[--table_prefix <paimon_table_prefix>] "
- + "[--table_suffix <paimon_table_suffix>] "
- + "[--including_tables
<mysql_table_name|name_regular_expr>] "
- + "[--excluding_tables
<mysql_table_name|name_regular_expr>] "
- + "[--mode <sync_mode>] "
- + "[--metadata_column <metadata_column>] "
- + "[--type_mapping <option1,option2...>] "
- + "[--mysql_conf <mysql_cdc_source_conf> [--mysql_conf
<mysql_cdc_source_conf> ...]] "
- + "[--catalog_conf <paimon_catalog_conf>
[--catalog_conf <paimon_catalog_conf> ...]] "
+ " mysql_sync_database \\\n"
+ + "--warehouse <warehouse_path> \\\n"
+ + "--database <database_name> \\\n"
+ + "[--ignore_incompatible <true/false>] \\\n"
+ + "[--merge_shards <true/false>] \\\n"
+ + "[--table_prefix <paimon_table_prefix>] \\\n"
+ + "[--table_suffix <paimon_table_suffix>] \\\n"
+ + "[--including_tables
<mysql_table_name|name_regular_expr>] \\\n"
+ + "[--excluding_tables
<mysql_table_name|name_regular_expr>] \\\n"
+ + "[--mode <sync_mode>] \\\n"
+ + "[--metadata_column <metadata_column>] \\\n"
+ + "[--type_mapping <option1,option2...>] \\\n"
+ + "[--mysql_conf <mysql_cdc_source_conf> [--mysql_conf
<mysql_cdc_source_conf> ...]] \\\n"
+ + "[--catalog_conf <paimon_catalog_conf>
[--catalog_conf <paimon_catalog_conf> ...]] \\\n"
+ "[--table_conf <paimon_table_sink_conf>
[--table_conf <paimon_table_sink_conf> ...]]");
System.out.println();
diff --git
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableActionFactory.java
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableActionFactory.java
index f4bb738617..e71f3f48a6 100644
---
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableActionFactory.java
+++
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableActionFactory.java
@@ -51,15 +51,17 @@ public class MySqlSyncTableActionFactory extends
SyncTableActionFactoryBase {
System.out.println("Syntax:");
System.out.println(
- " mysql_sync_table --warehouse <warehouse_path> --database
<database_name> "
- + "--table <table_name> "
- + "[--partition_keys <partition_keys>] "
- + "[--primary_keys <primary_keys>] "
- + "[--type_mapping <option1,option2...>] "
- + "[--computed_column <'column_name=expr_name(args[,
...])'> [--computed_column ...]] "
- + "[--metadata_column <metadata_column>] "
- + "[--mysql_conf <mysql_cdc_source_conf> [--mysql_conf
<mysql_cdc_source_conf> ...]] "
- + "[--catalog_conf <paimon_catalog_conf>
[--catalog_conf <paimon_catalog_conf> ...]] "
+ " mysql_sync_table \\\n"
+ + "--warehouse <warehouse_path> \\\n"
+ + "--database <database_name> \\\n"
+ + "--table <table_name> \\\n"
+ + "[--partition_keys <partition_keys>] \\\n"
+ + "[--primary_keys <primary_keys>] \\\n"
+ + "[--type_mapping <option1,option2...>] \\\n"
+ + "[--computed_column <'column_name=expr_name(args[,
...])'> [--computed_column ...]] \\\n"
+ + "[--metadata_column <metadata_column>] \\\n"
+ + "[--mysql_conf <mysql_cdc_source_conf> [--mysql_conf
<mysql_cdc_source_conf> ...]] \\\n"
+ + "[--catalog_conf <paimon_catalog_conf>
[--catalog_conf <paimon_catalog_conf> ...]] \\\n"
+ "[--table_conf <paimon_table_sink_conf>
[--table_conf <paimon_table_sink_conf> ...]]");
System.out.println();
diff --git
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/postgres/PostgresSyncTableActionFactory.java
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/postgres/PostgresSyncTableActionFactory.java
index a68f6366e5..d573be02b4 100644
---
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/postgres/PostgresSyncTableActionFactory.java
+++
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/postgres/PostgresSyncTableActionFactory.java
@@ -52,16 +52,17 @@ public class PostgresSyncTableActionFactory extends
SyncTableActionFactoryBase {
System.out.println("Syntax:");
System.out.println(
- " postgres_sync_table --warehouse <warehouse_path> --database
<database_name> "
- + "--table <table_name> "
- + "--table <table_name> "
- + "[--partition_keys <partition_keys>] "
- + "[--primary_keys <primary_keys>] "
- + "[--type_mapping <option1,option2...>] "
- + "[--computed_column <'column_name=expr_name(args[,
...])'> [--computed_column ...]] "
- + "[--metadata_column <metadata_column>] "
- + "[--postgres_conf <postgres_cdc_source_conf>
[--postgres_conf <postgres_cdc_source_conf> ...]] "
- + "[--catalog_conf <paimon_catalog_conf>
[--catalog_conf <paimon_catalog_conf> ...]] "
+ " postgres_sync_table \\\n"
+ + "--warehouse <warehouse_path> \\\n"
+ + "--database <database_name> \\\n"
+ + "--table <table_name> \\\n"
+ + "[--partition_keys <partition_keys>] \\\n"
+ + "[--primary_keys <primary_keys>] \\\n"
+ + "[--type_mapping <option1,option2...>] \\\n"
+ + "[--computed_column <'column_name=expr_name(args[,
...])'> [--computed_column ...]] \\\n"
+ + "[--metadata_column <metadata_column>] \\\n"
+ + "[--postgres_conf <postgres_cdc_source_conf>
[--postgres_conf <postgres_cdc_source_conf> ...]] \\\n"
+ + "[--catalog_conf <paimon_catalog_conf>
[--catalog_conf <paimon_catalog_conf> ...]] \\\n"
+ "[--table_conf <paimon_table_sink_conf>
[--table_conf <paimon_table_sink_conf> ...]]");
System.out.println();
diff --git
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarSyncDatabaseActionFactory.java
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarSyncDatabaseActionFactory.java
index 26af229c57..7008a577d9 100644
---
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarSyncDatabaseActionFactory.java
+++
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarSyncDatabaseActionFactory.java
@@ -54,14 +54,16 @@ public class PulsarSyncDatabaseActionFactory
System.out.println("Syntax:");
System.out.println(
- " pulsar_sync_database --warehouse <warehouse_path>
--database <database_name> "
- + "[--table_prefix <paimon_table_prefix>] "
- + "[--table_suffix <paimon_table_suffix>] "
- + "[--including_tables <table_name|name_regular_expr>]
"
- + "[--excluding_tables <table_name|name_regular_expr>]
"
- + "[--type_mapping <option1,option2...>] "
- + "[--pulsar_conf <pulsar_source_conf> [--pulsar_conf
<pulsar_source_conf> ...]] "
- + "[--catalog_conf <paimon_catalog_conf>
[--catalog_conf <paimon_catalog_conf> ...]] "
+ " pulsar_sync_database \\\n"
+ + "--warehouse <warehouse_path> \\\n"
+ + "--database <database_name> \\\n"
+ + "[--table_prefix <paimon_table_prefix>] \\\n"
+ + "[--table_suffix <paimon_table_suffix>] \\\n"
+ + "[--including_tables <table_name|name_regular_expr>]
\\\n"
+ + "[--excluding_tables <table_name|name_regular_expr>]
\\\n"
+ + "[--type_mapping <option1,option2...>] \\\n"
+ + "[--pulsar_conf <pulsar_source_conf> [--pulsar_conf
<pulsar_source_conf> ...]] \\\n"
+ + "[--catalog_conf <paimon_catalog_conf>
[--catalog_conf <paimon_catalog_conf> ...]] \\\n"
+ "[--table_conf <paimon_table_sink_conf>
[--table_conf <paimon_table_sink_conf> ...]]");
System.out.println();
diff --git
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarSyncTableActionFactory.java
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarSyncTableActionFactory.java
index 25822a7b87..db0c97bff5 100644
---
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarSyncTableActionFactory.java
+++
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarSyncTableActionFactory.java
@@ -51,14 +51,16 @@ public class PulsarSyncTableActionFactory extends
SyncTableActionFactoryBase {
System.out.println("Syntax:");
System.out.println(
- " pulsar_sync_table --warehouse <warehouse_path> --database
<database_name> "
- + "--table <table_name> "
- + "[--partition_keys <partition_keys>] "
- + "[--primary_keys <primary_keys>] "
- + "[--type_mapping <option1,option2...>] "
- + "[--computed_column <'column_name=expr_name(args[,
...])'> [--computed_column ...]] "
- + "[--pulsar_conf <pulsar_source_conf> [--pulsar_conf
<pulsar_source_conf> ...]] "
- + "[--catalog_conf <paimon_catalog_conf>
[--catalog_conf <paimon_catalog_conf> ...]] "
+ " pulsar_sync_table \\\n"
+ + "--warehouse <warehouse_path> \\\n"
+ + "--database <database_name> \\\n"
+ + "--table <table_name> \\\n"
+ + "[--partition_keys <partition_keys>] \\\n"
+ + "[--primary_keys <primary_keys>] \\\n"
+ + "[--type_mapping <option1,option2...>] \\\n"
+ + "[--computed_column <'column_name=expr_name(args[,
...])'> [--computed_column ...]] \\\n"
+ + "[--pulsar_conf <pulsar_source_conf> [--pulsar_conf
<pulsar_source_conf> ...]] \\\n"
+ + "[--catalog_conf <paimon_catalog_conf>
[--catalog_conf <paimon_catalog_conf> ...]] \\\n"
+ "[--table_conf <paimon_table_sink_conf>
[--table_conf <paimon_table_sink_conf> ...]]");
System.out.println();
