Github user jkbradley commented on a diff in the pull request:
https://github.com/apache/spark/pull/19843#discussion_r155403748
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamTest.scala ---
@@ -162,6 +168,12 @@ trait StreamTest extends QueryTest with
SharedSQLContext with TimeLimits with Be
private def operatorName = if (lastOnly) "CheckLastBatch" else
"CheckAnswer"
}
+ case class CheckAnswerRowsByFunc(checkFunction: Row => Unit, lastOnly:
Boolean)
+ extends StreamAction with StreamMustBeRunning {
--- End diff --
nit: style: indent +2 spaces
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
