Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/20650#discussion_r169604484
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala
---
@@ -543,6 +543,15 @@ abstract class StreamExecution(
Option(name).map(_ + "<br/>").getOrElse("") +
s"id = $id<br/>runId = $runId<br/>batch = $batchDescription"
}
+
+ private[sql] def withProgressLocked(f: => Unit): Unit = {
--- End diff --
TODO: Add docs.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
