[CYB-206] dev log removed (#73)

stas-panasiuk · web-flow · commit 12c12217a875 · 2024-04-20T17:15:05.000-04:00
diff --git a/flink-cyber/flink-indexing/flink-indexing-hive/src/main/java/com/cloudera/cyber/indexing/hive/util/AvroSchemaUtil.java b/flink-cyber/flink-indexing/flink-indexing-hive/src/main/java/com/cloudera/cyber/indexing/hive/util/AvroSchemaUtil.java
@@ -14,11 +14,7 @@
 import org.apache.flink.types.Row;
 
 import java.time.Instant;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
+import java.util.*;
 
 public class AvroSchemaUtil {
 
@@ -52,7 +48,6 @@ public static void putRowIntoAvro(Row row, GenericRecord record, String fieldNam
             }
         }
         record.put(avroFieldName, value);
-        System.out.println("fieldName: " + fieldName + " value: " + value);
     }
 
     private static Object convertToAvroObject(Schema fieldSchema, Object value) {

Original file line number	Diff line number	Diff line change
`@@ -14,11 +14,7 @@`
`14`	`14`	`import org.apache.flink.types.Row;`
`15`	`15`
`16`	`16`	`import java.time.Instant;`
`17`		`-import java.util.ArrayList;`
`18`		`-import java.util.HashMap;`
`19`		`-import java.util.List;`
`20`		`-import java.util.Map;`
`21`		`-import java.util.Set;`
	`17`	`+import java.util.*;`
`22`	`18`
`23`	`19`	`public class AvroSchemaUtil {`
`24`	`20`
`@@ -52,7 +48,6 @@ public static void putRowIntoAvro(Row row, GenericRecord record, String fieldNam`
`52`	`48`	`}`
`53`	`49`	`}`
`54`	`50`	`record.put(avroFieldName, value);`
`55`		`- System.out.println("fieldName: " + fieldName + " value: " + value);`
`56`	`51`	`}`
`57`	`52`
`58`	`53`	`private static Object convertToAvroObject(Schema fieldSchema, Object value) {`