Merge pull request #76 from lasanthaS/master

Fix build failure
siddhi-io · Jun 15, 2021 · 1e07c59 · 1e07c59
2 parents 3568bed + b687bc5
commit 1e07c59
Showing 1 changed file with 12 additions and 6 deletions.
diff --git a/...ent/src/main/java/io/siddhi/extension/io/cdc/source/listening/RdbmsChangeDataCapture.java b/...ent/src/main/java/io/siddhi/extension/io/cdc/source/listening/RdbmsChangeDataCapture.java
@@ -68,7 +68,8 @@ Map<String, Object> createMap(ConnectRecord connectRecord, String operation) {
                 case CDCSourceConstants.CONNECT_RECORD_INSERT_OPERATION:
                     if (operationList.contains(CDCSourceConstants.INSERT)) {
                         transportProperties.add(CDCSourceConstants.INSERT);
-                        transportProperties.add(record.getStruct(CDCSourceConstants.SOURCE_SCHEMA).get(CDCSourceConstants.EVENT_TIMESTAMP));
+                        transportProperties.add(record.getStruct(CDCSourceConstants.SOURCE_SCHEMA)
+                                .get(CDCSourceConstants.EVENT_TIMESTAMP));
                         transportProperties.add(record.get(CDCSourceConstants.EVENT_TIMESTAMP));
                         detailsMap.put(CDCSourceConstants.TRANSPORT_PROPERTIES, transportProperties);
                         rawDetails = (Struct) record.get(CDCSourceConstants.AFTER);
@@ -84,7 +85,8 @@ Map<String, Object> createMap(ConnectRecord connectRecord, String operation) {
                 case CDCSourceConstants.CONNECT_RECORD_UPDATE_OPERATION:
                     if (operationList.contains(CDCSourceConstants.UPDATE)) {
                         transportProperties.add(CDCSourceConstants.UPDATE);
-                        transportProperties.add(record.getStruct(CDCSourceConstants.SOURCE_SCHEMA).get(CDCSourceConstants.EVENT_TIMESTAMP));
+                        transportProperties.add(record.getStruct(CDCSourceConstants.SOURCE_SCHEMA)
+                                .get(CDCSourceConstants.EVENT_TIMESTAMP));
                         transportProperties.add(record.get(CDCSourceConstants.EVENT_TIMESTAMP));
                         detailsMap.put(CDCSourceConstants.TRANSPORT_PROPERTIES, transportProperties);
                         rawDetails = (Struct) record.get(CDCSourceConstants.BEFORE);
@@ -107,7 +109,8 @@ Map<String, Object> createMap(ConnectRecord connectRecord, String operation) {
                 case CDCSourceConstants.CONNECT_RECORD_DELETE_OPERATION:
                     if (operationList.contains(CDCSourceConstants.DELETE)) {
                         transportProperties.add(CDCSourceConstants.DELETE);
-                        transportProperties.add(record.getStruct(CDCSourceConstants.SOURCE_SCHEMA).get(CDCSourceConstants.EVENT_TIMESTAMP));
+                        transportProperties.add(record.getStruct(CDCSourceConstants.SOURCE_SCHEMA)
+                                .get(CDCSourceConstants.EVENT_TIMESTAMP));
                         transportProperties.add(record.get(CDCSourceConstants.EVENT_TIMESTAMP));
                         detailsMap.put(CDCSourceConstants.TRANSPORT_PROPERTIES, transportProperties);
                         rawDetails = (Struct) record.get(CDCSourceConstants.BEFORE);
@@ -135,7 +138,8 @@ Map<String, Object> createMap(ConnectRecord connectRecord, String operation) {
             switch (op) {
                 case CDCSourceConstants.CONNECT_RECORD_INSERT_OPERATION:
                     transportProperties.add(CDCSourceConstants.INSERT);
-                    transportProperties.add(record.getStruct(CDCSourceConstants.SOURCE_SCHEMA).get(CDCSourceConstants.EVENT_TIMESTAMP));
+                    transportProperties.add(record.getStruct(CDCSourceConstants.SOURCE_SCHEMA)
+                            .get(CDCSourceConstants.EVENT_TIMESTAMP));
                     transportProperties.add(record.get(CDCSourceConstants.EVENT_TIMESTAMP));
                     detailsMap.put(CDCSourceConstants.TRANSPORT_PROPERTIES, transportProperties);
                     //append row details after insert.
@@ -148,7 +152,8 @@ Map<String, Object> createMap(ConnectRecord connectRecord, String operation) {
                     break;
                 case CDCSourceConstants.CONNECT_RECORD_DELETE_OPERATION:
                     transportProperties.add(CDCSourceConstants.DELETE);
-                    transportProperties.add(record.getStruct(CDCSourceConstants.SOURCE_SCHEMA).get(CDCSourceConstants.EVENT_TIMESTAMP));
+                    transportProperties.add(record.getStruct(CDCSourceConstants.SOURCE_SCHEMA)
+                            .get(CDCSourceConstants.EVENT_TIMESTAMP));
                     transportProperties.add(record.get(CDCSourceConstants.EVENT_TIMESTAMP));
                     detailsMap.put(CDCSourceConstants.TRANSPORT_PROPERTIES, transportProperties);
                     //append row details before delete.
@@ -162,7 +167,8 @@ Map<String, Object> createMap(ConnectRecord connectRecord, String operation) {
                     break;
                 case CDCSourceConstants.CONNECT_RECORD_UPDATE_OPERATION:
                     transportProperties.add(CDCSourceConstants.UPDATE);
-                    transportProperties.add(record.getStruct(CDCSourceConstants.SOURCE_SCHEMA).get(CDCSourceConstants.EVENT_TIMESTAMP));
+                    transportProperties.add(record.getStruct(CDCSourceConstants.SOURCE_SCHEMA)
+                            .get(CDCSourceConstants.EVENT_TIMESTAMP));
                     transportProperties.add(record.get(CDCSourceConstants.EVENT_TIMESTAMP));
                     detailsMap.put(CDCSourceConstants.TRANSPORT_PROPERTIES, transportProperties);
                     //append row details before update.