Merge pull request #98 from data-integrations/fix/compilation

Fixed compilation failures for new tests.

Author: sagarkapare

mysql-delta-plugins/src/test/java/io/cdap/delta/mysql/MySqlEventReaderIntegrationTest.java

@@ -197,9 +197,9 @@ public void test() throws InterruptedException {
     Assert.assertEquals(expected, row);
 
     dmlEvent = eventEmitter.getDmlEvents().get(2);
-    Assert.assertEquals(DMLOperation.INSERT, dmlEvent.getOperation());
+    Assert.assertEquals(DMLOperation.Type.INSERT, dmlEvent.getOperation().getType());
     Assert.assertEquals(DB, dmlEvent.getDatabase());
-    Assert.assertEquals(CUSTOMERS_TABLE, dmlEvent.getTable());
+    Assert.assertEquals(CUSTOMERS_TABLE, dmlEvent.getOperation().getTableName());
     row = dmlEvent.getRow();
     expected = StructuredRecord.builder(CUSTOMERS_SCHEMA)
       .set("id", 2)

sqlserver-delta-plugins/src/test/java/io.cdap.delta.sqlserver/SqlServerEventReaderIntegrationTest.java

@@ -201,9 +201,9 @@ public void test() throws InterruptedException {
     Assert.assertEquals(expected, row);
 
     dmlEvent = eventEmitter.getDmlEvents().get(2);
-    Assert.assertEquals(DMLOperation.INSERT, dmlEvent.getOperation());
+    Assert.assertEquals(DMLOperation.Type.INSERT, dmlEvent.getOperation().getType());
     Assert.assertEquals(DB, dmlEvent.getDatabase());
-    Assert.assertEquals(CUSTOMERS_TABLE, dmlEvent.getTable());
+    Assert.assertEquals(CUSTOMERS_TABLE, dmlEvent.getOperation().getTableName());
     row = dmlEvent.getRow();
     expected = StructuredRecord.builder(CUSTOMERS_SCHEMA)
       .set("id", 2)