Merge pull request #541 from juripetersen/explain-json-in-dataquanta

Add default toJson argument for explain

Author: juripetersen

wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/DataQuanta.scala

@@ -942,7 +942,7 @@ class DataQuanta[Out: ClassTag](val operator: ElementaryOperator, outputIndex: I
     collector
   }
 
-  def explain(): Unit = {
+  def explain(toJson: Boolean = false): Unit = {
     // Set up the sink.
     val collector = new java.util.LinkedList[Out]()
     val sink = LocalCallbackSink.createCollectingSink(collector, dataSetType[Out])
@@ -951,7 +951,7 @@ class DataQuanta[Out: ClassTag](val operator: ElementaryOperator, outputIndex: I
 
     // Do the explanation.
     this.planBuilder.sinks += sink
-    this.planBuilder.buildAndExplain()
+    this.planBuilder.buildAndExplain(toJson)
   }
 
 

wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/PlanBuilder.scala

@@ -109,9 +109,13 @@ class PlanBuilder(private[api] val wayangContext: WayangContext, private var job
   /**
     * Build the [[org.apache.wayang.core.api.Job]] and explain it.
     */
-  def buildAndExplain(): Unit = {
+  def buildAndExplain(toJson: Boolean = false): Unit = {
     val plan: WayangPlan = new WayangPlan(this.sinks.toArray: _*)
-    this.wayangContext.explain(plan, this.udfJars.toArray: _*)
+    if (toJson) {
+      this.wayangContext.explain(plan, toJson, this.udfJars.toArray: _*)
+    } else {
+      this.wayangContext.explain(plan, this.udfJars.toArray: _*)
+    }
   }
 
   /**