Add default toJson argument for explain

juripetersen · juripetersen · commit 4e303687fd77 · 2025-04-10T11:25:40.000+02:00
diff --git a/wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/DataQuanta.scala b/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)
   }
 
 

Original file line number	Diff line number	Diff line change
`@@ -942,7 +942,7 @@ class DataQuanta[Out: ClassTag](val operator: ElementaryOperator, outputIndex: I`
`942`	`942`	`collector`
`943`	`943`	`}`
`944`	`944`
`945`		`- def explain(): Unit = {`
	`945`	`+ def explain(toJson: Boolean = false): Unit = {`
`946`	`946`	`// Set up the sink.`
`947`	`947`	`val collector = new java.util.LinkedList[Out]()`
`948`	`948`	`val sink = LocalCallbackSink.createCollectingSink(collector, dataSetType[Out])`
`@@ -951,7 +951,7 @@ class DataQuanta[Out: ClassTag](val operator: ElementaryOperator, outputIndex: I`
`951`	`951`
`952`	`952`	`// Do the explanation.`
`953`	`953`	`this.planBuilder.sinks += sink`
`954`		`- this.planBuilder.buildAndExplain()`
	`954`	`+ this.planBuilder.buildAndExplain(toJson)`
`955`	`955`	`}`
`956`	`956`
`957`	`957`