You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@paimon.apache.org by yu...@apache.org on 2025/02/11 04:07:12 UTC
(paimon) branch master updated: [cdc] Add line breaks to cdc action help message to improve readability (#5032)
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 <54...@users.noreply.github.com>
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();