System.out is replace by a logger

[dcaegen2/services.git] / components / datalake-handler / feeder / src / main / java / org / onap / datalake / feeder / util / DruidSupervisorGenerator.java

diff --git a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/util/DruidSupervisorGenerator.java b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/util/DruidSupervisorGenerator.java
index 8a177cc..51d3168 100644 (file)
--- a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/util/DruidSupervisorGenerator.java
+++ b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/util/DruidSupervisorGenerator.java
@@ -28,6 +28,8 @@ import org.apache.velocity.VelocityContext;
 import org.apache.velocity.app.Velocity;\r
 import org.apache.velocity.runtime.RuntimeConstants;\r
 import org.apache.velocity.runtime.resource.loader.ClasspathResourceLoader;\r
+import org.slf4j.Logger;\r
+import org.slf4j.LoggerFactory;\r
 \r
 import java.io.BufferedWriter;\r
 import java.io.FileWriter;\r
@@ -59,6 +61,8 @@ import java.util.Map.Entry;
 @Getter\r
 public class DruidSupervisorGenerator {\r
 \r
+    private final Logger log = LoggerFactory.getLogger(this.getClass());\r
+\r
     Template template = null;\r
     VelocityContext context;\r
 \r
@@ -90,7 +94,6 @@ public class DruidSupervisorGenerator {
 \r
             while (fields.hasNext()) {\r
                 Entry<String, JsonNode> field = fields.next();\r
-                //                             System.out.println("--------"+field.getKey()+"--------");\r
                 printNode(prefix + "." + field.getKey(), field.getValue());\r
             }\r
 \r
@@ -113,25 +116,13 @@ public class DruidSupervisorGenerator {
     private void printFlattenSpec(JsonNodeType type, String path) {\r
         String name = path.substring(2).replace('.', ':');\r
         // lets see what type the node is\r
-        System.out.println("{");\r
-        System.out.println("\"type\": \"path\",");\r
-        System.out.println("\"name\": \"" + name + "\",");\r
-        System.out.println("\"expr\": \"" + path + "\"");\r
-        System.out.println("},");\r
+        log.info("{");\r
+        log.info("\"type\": \"path\",");\r
+        log.info("\"name\": \"" + name + "\",");\r
+        log.info("\"expr\": \"" + path + "\"");\r
+        log.info("},");\r
 \r
         dimensions.add(new String[]{name, path});\r
-               /*\r
-                //for  dimensionsSpec\r
-                               if (JsonNodeType.NUMBER.equals(type)) {\r
-                                       System.out.println("{");\r
-                                       System.out.println("\"type\": \"long\",");\r
-                                       System.out.println("\"name\": \"" + name + "\","); \r
-                                       System.out.println("},");\r
-                               } else {\r
-                                       System.out.println("\"" + name + "\",");\r
-               \r
-                               }\r
-               */\r
     }\r
 \r
     public void doTopic(String topic) throws IOException {\r