Repository: spark Updated Branches: refs/heads/branch-2.2 9afab9a52 -> 342cc2a4c
[SPARK-21901][SS] Define toString for StateOperatorProgress ## What changes were proposed in this pull request? Just `StateOperatorProgress.toString` + few formatting fixes ## How was this patch tested? Local build. Waiting for OK from Jenkins. Author: Jacek Laskowski <[email protected]> Closes #19112 from jaceklaskowski/SPARK-21901-StateOperatorProgress-toString. (cherry picked from commit fa0092bddf695a757f5ddaed539e55e2dc9fccb7) Signed-off-by: Shixiong Zhu <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/342cc2a4 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/342cc2a4 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/342cc2a4 Branch: refs/heads/branch-2.2 Commit: 342cc2a4cad4b8491f4689b66570d14e5fcba33b Parents: 9afab9a Author: Jacek Laskowski <[email protected]> Authored: Wed Sep 6 15:48:48 2017 -0700 Committer: Shixiong Zhu <[email protected]> Committed: Wed Sep 6 15:49:03 2017 -0700 ---------------------------------------------------------------------- .../src/main/scala/org/apache/spark/sql/streaming/progress.scala | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/342cc2a4/sql/core/src/main/scala/org/apache/spark/sql/streaming/progress.scala ---------------------------------------------------------------------- diff --git a/sql/core/src/main/scala/org/apache/spark/sql/streaming/progress.scala b/sql/core/src/main/scala/org/apache/spark/sql/streaming/progress.scala index fb590e7..5171852 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/streaming/progress.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/streaming/progress.scala @@ -49,6 +49,8 @@ class StateOperatorProgress private[sql]( ("numRowsTotal" -> JInt(numRowsTotal)) ~ ("numRowsUpdated" -> JInt(numRowsUpdated)) } + + override def toString: String = prettyJson } /** --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
