[incubator-paimon] branch master updated: [filnk] make kafka sync action to public (#1627)

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 2df17081c [filnk] make kafka sync action to public (#1627)
2df17081c is described below

commit 2df17081cf32e1780a7791bea92ba9e33811eb31
Author: JunZhang <zhangjunem...@126.com>
AuthorDate: Mon Jul 31 17:22:25 2023 +0800

    [filnk] make kafka sync action to public (#1627)
---
 .../main/java/org/apache/paimon/flink/action/DropPartitionAction.java | 2 +-
 .../src/main/java/org/apache/paimon/flink/action/MergeIntoAction.java | 4 ++--
 .../apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java | 4 ++--
 .../apache/paimon/flink/action/cdc/kafka/KafkaSyncTableAction.java    | 2 +-
 4 files changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/DropPartitionAction.java
 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/DropPartitionAction.java
index df3c69656..a1bd77544 100644
--- 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/DropPartitionAction.java
+++ 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/DropPartitionAction.java
@@ -33,7 +33,7 @@ public class DropPartitionAction extends TableActionBase {
     private final List<Map<String, String>> partitions;
     private final FileStoreCommit commit;
 
-    DropPartitionAction(
+    public DropPartitionAction(
             String warehouse,
             String databaseName,
             String tableName,
diff --git 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/MergeIntoAction.java
 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/MergeIntoAction.java
index adc4e7806..60b8a710b 100644
--- 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/MergeIntoAction.java
+++ 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/MergeIntoAction.java
@@ -117,11 +117,11 @@ public class MergeIntoAction extends TableActionBase {
     @Nullable private String notMatchedInsertCondition;
     @Nullable private String notMatchedInsertValues;
 
-    MergeIntoAction(String warehouse, String database, String tableName) {
+    public MergeIntoAction(String warehouse, String database, String 
tableName) {
         this(warehouse, database, tableName, Collections.emptyMap());
     }
 
-    MergeIntoAction(
+    public MergeIntoAction(
             String warehouse,
             String database,
             String tableName,
diff --git 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java
 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java
index b4894a31d..0791b3df1 100644
--- 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java
+++ 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java
@@ -89,7 +89,7 @@ public class KafkaSyncDatabaseAction extends ActionBase {
     @Nullable private final Pattern excludingPattern;
     private final Map<String, String> tableConfig;
 
-    KafkaSyncDatabaseAction(
+    public KafkaSyncDatabaseAction(
             Map<String, String> kafkaConfig,
             String warehouse,
             String database,
@@ -98,7 +98,7 @@ public class KafkaSyncDatabaseAction extends ActionBase {
         this(kafkaConfig, warehouse, database, null, null, null, null, 
catalogConfig, tableConfig);
     }
 
-    KafkaSyncDatabaseAction(
+    public KafkaSyncDatabaseAction(
             Map<String, String> kafkaConfig,
             String warehouse,
             String database,
diff --git 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableAction.java
 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableAction.java
index 7ebd1e03f..8d25e1c04 100644
--- 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableAction.java
+++ 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableAction.java
@@ -88,7 +88,7 @@ public class KafkaSyncTableAction extends ActionBase {
 
     private final Map<String, String> paimonConfig;
 
-    KafkaSyncTableAction(
+    public KafkaSyncTableAction(
             Map<String, String> kafkaConfig,
             String warehouse,
             String database,