spark git commit: [SPARK-21901][SS] Define toString for StateOperatorProgress
Repository: spark Updated Branches: refs/heads/master acdf45fb5 -> fa0092bdd [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 Closes #19112 from jaceklaskowski/SPARK-21901-StateOperatorProgress-toString. Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/fa0092bd Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/fa0092bd Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/fa0092bd Branch: refs/heads/master Commit: fa0092bddf695a757f5ddaed539e55e2dc9fccb7 Parents: acdf45f Author: Jacek Laskowski Authored: Wed Sep 6 15:48:48 2017 -0700 Committer: Shixiong Zhu Committed: Wed Sep 6 15:48:48 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/fa0092bd/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 3000c42..cedc1dc 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 @@ -55,6 +55,8 @@ class StateOperatorProgress private[sql]( ("numRowsUpdated" -> JInt(numRowsUpdated)) ~ ("memoryUsedBytes" -> JInt(memoryUsedBytes)) } + + override def toString: String = prettyJson } /** - To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org
spark git commit: [SPARK-21901][SS] Define toString for StateOperatorProgress
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 Closes #19112 from jaceklaskowski/SPARK-21901-StateOperatorProgress-toString. (cherry picked from commit fa0092bddf695a757f5ddaed539e55e2dc9fccb7) Signed-off-by: Shixiong Zhu 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 Authored: Wed Sep 6 15:48:48 2017 -0700 Committer: Shixiong Zhu 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: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org