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/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 0312df50ce [hotfix] Rename MongdbSchemaUtils to MongDBSchemaUtils
(#5091)
0312df50ce is described below
commit 0312df50ce7968093909ffdecacac0ee4f371bbc
Author: yangjf2019 <[email protected]>
AuthorDate: Mon Feb 17 09:56:10 2025 +0800
[hotfix] Rename MongdbSchemaUtils to MongDBSchemaUtils (#5091)
---
.../{MongodbSchemaUtils.java => MongoDBSchemaUtils.java} | 2 +-
.../flink/action/cdc/mongodb/MongoDBSyncTableAction.java | 2 +-
...MongodbSchemaITCase.java => MongoDBSchemaITCase.java} | 16 ++++++++--------
3 files changed, 10 insertions(+), 10 deletions(-)
diff --git
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongodbSchemaUtils.java
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSchemaUtils.java
similarity index 99%
rename from
paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongodbSchemaUtils.java
rename to
paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSchemaUtils.java
index 76c936a32d..9d7aca5f1c 100644
---
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongodbSchemaUtils.java
+++
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSchemaUtils.java
@@ -52,7 +52,7 @@ import static
org.apache.paimon.flink.action.cdc.mongodb.MongoDBActionUtils.STAR
* schema details are provided explicitly, while in the DYNAMIC mode, the
schema is inferred from
* the first document in the collection.
*/
-public class MongodbSchemaUtils {
+public class MongoDBSchemaUtils {
private static final String ID_FIELD = "_id";
diff --git
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSyncTableAction.java
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSyncTableAction.java
index a4ef4e0d60..4dbb74471c 100644
---
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSyncTableAction.java
+++
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSyncTableAction.java
@@ -60,7 +60,7 @@ public class MongoDBSyncTableAction extends
SyncTableActionBase {
@Override
protected Schema retrieveSchema() {
- return MongodbSchemaUtils.getMongodbSchema(cdcSourceConfig);
+ return MongoDBSchemaUtils.getMongodbSchema(cdcSourceConfig);
}
@Override
diff --git
a/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mongodb/MongodbSchemaITCase.java
b/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSchemaITCase.java
similarity index 93%
rename from
paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mongodb/MongodbSchemaITCase.java
rename to
paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSchemaITCase.java
index f0328b5663..3ad5e4941b 100644
---
a/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mongodb/MongodbSchemaITCase.java
+++
b/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSchemaITCase.java
@@ -43,8 +43,8 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertThrows;
-/** Tests for {@link MongodbSchemaUtils}. */
-public class MongodbSchemaITCase extends MongoDBActionITCaseBase {
+/** Tests for {@link MongoDBSchemaUtils}. */
+public class MongoDBSchemaITCase extends MongoDBActionITCaseBase {
@BeforeAll
public static void initMongoDB() {
@@ -82,7 +82,7 @@ public class MongodbSchemaITCase extends
MongoDBActionITCaseBase {
mongodbConfig.set(MongoDBSourceOptions.CONNECTION_OPTIONS,
"authSource=admin");
mongodbConfig.set(MongoDBSourceOptions.DATABASE, "testDatabase");
mongodbConfig.set(MongoDBSourceOptions.COLLECTION, "testCollection");
- Schema schema = MongodbSchemaUtils.getMongodbSchema(mongodbConfig);
+ Schema schema = MongoDBSchemaUtils.getMongodbSchema(mongodbConfig);
assertNotNull(schema);
}
@@ -97,7 +97,7 @@ public class MongodbSchemaITCase extends
MongoDBActionITCaseBase {
mongodbConfig.set(MongoDBSourceOptions.COLLECTION, "testCollection");
assertThrows(
- RuntimeException.class, () ->
MongodbSchemaUtils.getMongodbSchema(mongodbConfig));
+ RuntimeException.class, () ->
MongoDBSchemaUtils.getMongodbSchema(mongodbConfig));
}
@Test
@@ -108,7 +108,7 @@ public class MongodbSchemaITCase extends
MongoDBActionITCaseBase {
// Expect an exception to be thrown due to missing necessary settings
assertThrows(
NullPointerException.class,
- () -> MongodbSchemaUtils.getMongodbSchema(mongodbConfig));
+ () -> MongoDBSchemaUtils.getMongodbSchema(mongodbConfig));
}
@Test
@@ -123,7 +123,7 @@ public class MongodbSchemaITCase extends
MongoDBActionITCaseBase {
mongodbConfig.set(MongoDBSourceOptions.COLLECTION, "testCollection");
// Call the method and check the results
- Schema schema = MongodbSchemaUtils.getMongodbSchema(mongodbConfig);
+ Schema schema = MongoDBSchemaUtils.getMongodbSchema(mongodbConfig);
// Verify the schema
assertNotNull(schema);
@@ -147,7 +147,7 @@ public class MongodbSchemaITCase extends
MongoDBActionITCaseBase {
mongodbConfig.set(MongoDBSourceOptions.COLLECTION, "testCollection");
assertThrows(
- RuntimeException.class, () ->
MongodbSchemaUtils.getMongodbSchema(mongodbConfig));
+ RuntimeException.class, () ->
MongoDBSchemaUtils.getMongodbSchema(mongodbConfig));
}
@Test
@@ -161,6 +161,6 @@ public class MongodbSchemaITCase extends
MongoDBActionITCaseBase {
mongodbConfig.set(MongoDBSourceOptions.COLLECTION,
"invalidCollection");
assertThrows(
- RuntimeException.class, () ->
MongodbSchemaUtils.getMongodbSchema(mongodbConfig));
+ RuntimeException.class, () ->
MongoDBSchemaUtils.getMongodbSchema(mongodbConfig));
}
}
