Skip to content

Commit a9c4ba9

Browse files
committed
Add buildAndExplain with toJson args to PlanBuilder
1 parent 4e30368 commit a9c4ba9

1 file changed

Lines changed: 6 additions & 2 deletions

File tree

  • wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api

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

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -109,9 +109,13 @@ class PlanBuilder(private[api] val wayangContext: WayangContext, private var job
109109
/**
110110
* Build the [[org.apache.wayang.core.api.Job]] and explain it.
111111
*/
112-
def buildAndExplain(): Unit = {
112+
def buildAndExplain(toJson: Boolean = false): Unit = {
113113
val plan: WayangPlan = new WayangPlan(this.sinks.toArray: _*)
114-
this.wayangContext.explain(plan, this.udfJars.toArray: _*)
114+
if (toJson) {
115+
this.wayangContext.explain(plan, toJson, this.udfJars.toArray: _*)
116+
} else {
117+
this.wayangContext.explain(plan, this.udfJars.toArray: _*)
118+
}
115119
}
116120

117121
/**

0 commit comments

Comments
 (0)