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
