@test public void dagToStringConvert() { LogicalPlan dag = new LogicalPlan(); Application app = new Application(); Configuration conf = new Configuration(false); conf.addResource("dt-site-pi.xml"); app.populateDAG(dag, conf); LogicalPlanSerializer serializer = new LogicalPlanSerializer(); JSONObject json = serializer.convertToJsonObject(dag); S…

dagtoString.java

  @Test
  public void dagToStringConvert()
  {
    LogicalPlan dag = new LogicalPlan();
    Application app = new Application();
    Configuration conf = new Configuration(false);
    conf.addResource("dt-site-pi.xml");
    app.populateDAG(dag, conf);
    LogicalPlanSerializer serializer = new LogicalPlanSerializer();
    JSONObject json = serializer.convertToJsonObject(dag);
    StringWriter sw = new StringWriter();
    PrintWriter writer = new PrintWriter(sw);
    writer.write(json.toString());
    writer.flush();
    System.out.println(sw.getBuffer());
  }