代码格式修复（spotless apply）

Author: zhuxt2015

dinky-cdc/dinky-cdc-core/src/main/java/org/dinky/cdc/sql/SQLSinkBuilder.java

@@ -105,7 +105,8 @@ private List<Operation> addSinkInsert(
             sinkTableObject = table;
         }
         String pkList = StringUtils.join(getPKList(sinkTableObject), ".");
-        String flinkDDL = FlinkStatementUtil.getFlinkDDL(sinkTableObject, targetTable, config, sinkSchemaName, sinkTable, pkList);
+        String flinkDDL =
+                FlinkStatementUtil.getFlinkDDL(sinkTableObject, targetTable, config, sinkSchemaName, sinkTable, pkList);
         logger.info(flinkDDL);
         customTableEnvironment.executeSql(flinkDDL);
         logger.info("Create {} FlinkSQL DDL successful...", targetTable);

dinky-cdc/dinky-cdc-core/src/test/java/org/dinky/cdc/postgres/PostgresCDCBuilderTest.java

@@ -108,7 +108,10 @@ public void testParseMetaDataConfig_multipleJdbcProperties() {
         Assert.assertTrue("URL should contain sslmode param", url.contains("sslmode=require"));
         Assert.assertFalse("URL must not end with '&'", url.endsWith("&"));
         // Exactly one '?' in the query string part
-        Assert.assertEquals("URL should have exactly one '?'", 1, url.chars().filter(c -> c == '?').count());
+        Assert.assertEquals(
+                "URL should have exactly one '?'",
+                1,
+                url.chars().filter(c -> c == '?').count());
     }
 
     /** Host / port embedded correctly in URL */

dinky-core/src/main/java/org/dinky/trans/ddl/CreateCDCSourceOperation.java

@@ -130,7 +130,7 @@ public TableResult execute(Executor executor) {
                     table.setColumns(driver.listColumnsSortByPK(realSchemaName, tableName));
                     schemaList.add(schema);
                     Driver sinkRealDriver = getDriver(config, schemaName);
-                    final List<Table> sinkTables= getSinkTables(config, schemaName);
+                    final List<Table> sinkTables = getSinkTables(config, schemaName);
                     setSinkTable(table, sinkTables, sinkBuilder, sinkRealDriver);
                     if (null != sinkDriver) {
                         final String createTableOptions = config.getSink().get(FlinkCDCConfig.AUTO_CREATE_OPTIONS);
@@ -154,7 +154,7 @@ public TableResult execute(Executor executor) {
 
                     final List<Table> tables = driver.listTables(schemaName);
                     Driver sinkRealDriver = getDriver(config, schemaName);
-                    final List<Table> sinkTables= getSinkTables(config, schemaName);
+                    final List<Table> sinkTables = getSinkTables(config, schemaName);
                     for (Table table : tables) {
                         if (!Asserts.isEquals(table.getType(), "VIEW")) {
                             if (Asserts.isNotNullCollection(tableRegList)) {
@@ -229,7 +229,8 @@ public TableResult execute(Executor executor) {
         return tableResultBuilder.build();
     }
 
-    private static void setSinkTable(Table table, List<Table> sinkTables, SinkBuilder sinkBuilder, Driver sinkRealDriver) {
+    private static void setSinkTable(
+            Table table, List<Table> sinkTables, SinkBuilder sinkBuilder, Driver sinkRealDriver) {
         String sinkTableName = sinkBuilder.getSinkTableName(table);
         for (Table sinkTable : sinkTables) {
             String sinkTableSchema = sinkTable.getSchema();

dinky-core/src/test/java/org/dinky/trans/ddl/CreateCDCSourceOperationTest.java

@@ -47,15 +47,14 @@ class CreateCDCSourceOperationTest {
     @BeforeEach
     void setUp() throws Exception {
         setSinkTableMethod = CreateCDCSourceOperation.class.getDeclaredMethod(
-                "setSinkTable", Table.class, List.class, SinkBuilder.class,
-                org.dinky.metadata.driver.Driver.class);
+                "setSinkTable", Table.class, List.class, SinkBuilder.class, org.dinky.metadata.driver.Driver.class);
         setSinkTableMethod.setAccessible(true);
 
         sinkBuilder = mock(SinkBuilder.class);
     }
 
-    private void invoke(Table table, List<Table> sinkTables, SinkBuilder sb,
-            org.dinky.metadata.driver.Driver driver) throws Exception {
+    private void invoke(Table table, List<Table> sinkTables, SinkBuilder sb, org.dinky.metadata.driver.Driver driver)
+            throws Exception {
         setSinkTableMethod.invoke(null, table, sinkTables, sb, driver);
     }
 
@@ -119,8 +118,7 @@ void testMatchWithDriver_columnsAreSet() throws Exception {
         when(sinkBuilder.getSinkTableName(sourceTable)).thenReturn("orders");
 
         org.dinky.metadata.driver.Driver driver = mock(org.dinky.metadata.driver.Driver.class);
-        when(driver.listColumnsSortByPK("public", "orders"))
-                .thenReturn(Collections.emptyList());
+        when(driver.listColumnsSortByPK("public", "orders")).thenReturn(Collections.emptyList());
 
         invoke(sourceTable, Collections.singletonList(sinkTable), sinkBuilder, driver);