spotless

Author: derrickaw

v2/cdc-parent/cdc-embedded-connector/src/main/java/com/google/cloud/dataflow/cdc/connector/DebeziumToPubSubDataSender.java

@@ -149,8 +149,7 @@ public DebeziumToPubSubDataSender(
       LOG.info("Setting up in memory offset storage.");
       configBuilder =
           configBuilder.with(
-              "offset.storage",
-              "org.apache.kafka.connect.storage.MemoryOffsetBackingStore");
+              "offset.storage", "org.apache.kafka.connect.storage.MemoryOffsetBackingStore");
     } else {
       LOG.info("Setting up in File-based offset storage in {}.", this.offsetStorageFile);
       configBuilder =

v2/cdc-parent/cdc-embedded-connector/src/main/java/com/google/cloud/dataflow/cdc/connector/PubSubChangeConsumer.java

@@ -41,7 +41,8 @@
 import org.slf4j.LoggerFactory;
 
 /** Implements Debezium's Embedded Engine change consumer to push data to PubSub. */
-public class PubSubChangeConsumer implements DebeziumEngine.ChangeConsumer<ChangeEvent<SourceRecord, SourceRecord>> {
+public class PubSubChangeConsumer
+    implements DebeziumEngine.ChangeConsumer<ChangeEvent<SourceRecord, SourceRecord>> {
 
   private static final org.slf4j.Logger LOG = LoggerFactory.getLogger(PubSubChangeConsumer.class);
 
@@ -101,7 +102,9 @@ private RowCoder getCoderForRow(String tableName, Row record) {
   }
 
   @Override
-  public void handleBatch(List<ChangeEvent<SourceRecord, SourceRecord>> records, RecordCommitter<ChangeEvent<SourceRecord, SourceRecord>> committer)
+  public void handleBatch(
+      List<ChangeEvent<SourceRecord, SourceRecord>> records,
+      RecordCommitter<ChangeEvent<SourceRecord, SourceRecord>> committer)
       throws InterruptedException {
 
     ImmutableList.Builder<ApiFuture<String>> futureListBuilder = ImmutableList.builder();

v2/cdc-parent/cdc-embedded-connector/src/test/java/com/google/cloud/dataflow/cdc/connector/PubSubChangeConsumerTest.java

@@ -90,51 +90,55 @@ public void testBasicRecordAndFilteredRecordInput() throws InterruptedException
     // is whitelisted, therefore, only one will be published to pubsub.
     ChangeEvent<SourceRecord, SourceRecord> mockEvent1 = Mockito.mock(ChangeEvent.class);
     ChangeEvent<SourceRecord, SourceRecord> mockEvent2 = Mockito.mock(ChangeEvent.class);
-    
-    SourceRecord record1 = new SourceRecord(
-                ImmutableMap.of("server", "mainstance"),
-                ImmutableMap.of(
-                    "file",
-                    "mysql-bin.000023",
-                    "pos",
-                    110489,
-                    "gtids",
-                    "36797132-a366-11e9-ac33-42010a800456:1-6407169",
-                    "row",
-                    1,
-                    "snapshot",
-                    true),
-                topicName,
-                keySchema,
-                key,
-                valueSchema,
-                value);
-    
-    SourceRecord record2 = new SourceRecord(
-                ImmutableMap.of("server", "mainstance"),
-                ImmutableMap.of(
-                    "file",
-                    "mysql-bin.000023",
-                    "pos",
-                    110490,
-                    "gtids",
-                    "36797132-a366-11e9-ac33-42010a800456:1-6407169",
-                    "row",
-                    1,
-                    "snapshot",
-                    true),
-                "NOTWHITELISTEDTOPIC!", // A topic that was NOT whitelisted
-                keySchema,
-                key,
-                valueSchema,
-                value);
+
+    SourceRecord record1 =
+        new SourceRecord(
+            ImmutableMap.of("server", "mainstance"),
+            ImmutableMap.of(
+                "file",
+                "mysql-bin.000023",
+                "pos",
+                110489,
+                "gtids",
+                "36797132-a366-11e9-ac33-42010a800456:1-6407169",
+                "row",
+                1,
+                "snapshot",
+                true),
+            topicName,
+            keySchema,
+            key,
+            valueSchema,
+            value);
+
+    SourceRecord record2 =
+        new SourceRecord(
+            ImmutableMap.of("server", "mainstance"),
+            ImmutableMap.of(
+                "file",
+                "mysql-bin.000023",
+                "pos",
+                110490,
+                "gtids",
+                "36797132-a366-11e9-ac33-42010a800456:1-6407169",
+                "row",
+                1,
+                "snapshot",
+                true),
+            "NOTWHITELISTEDTOPIC!", // A topic that was NOT whitelisted
+            keySchema,
+            key,
+            valueSchema,
+            value);
 
     Mockito.when(mockEvent1.value()).thenReturn(record1);
     Mockito.when(mockEvent2.value()).thenReturn(record2);
 
-    List<ChangeEvent<SourceRecord, SourceRecord>> recordBatch = ImmutableList.of(mockEvent1, mockEvent2);
+    List<ChangeEvent<SourceRecord, SourceRecord>> recordBatch =
+        ImmutableList.of(mockEvent1, mockEvent2);
 
-    RecordCommitter<ChangeEvent<SourceRecord, SourceRecord>> mockCommitter = Mockito.mock(RecordCommitter.class);
+    RecordCommitter<ChangeEvent<SourceRecord, SourceRecord>> mockCommitter =
+        Mockito.mock(RecordCommitter.class);
 
     changeConsumer.handleBatch(recordBatch, mockCommitter);