Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/20650#discussion_r169605919
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamTest.scala ---
@@ -217,6 +225,14 @@ trait StreamTest extends QueryTest with
SharedSQLContext with TimeLimits with Be
s"ExpectFailure[${causeClass.getName}, isFatalError: $isFatalError]"
}
+ case class StreamProgressLockedActions(actions: Seq[StreamAction], desc:
String = null)
--- End diff --
TODO: add docs.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
