Repository: spark Updated Branches: refs/heads/branch-1.2 bd70ff99e -> 14dbd8312
[SPARK-5028][Streaming]Add total received and processed records metrics to Streaming UI This is a follow-up work of [SPARK-4537](https://issues.apache.org/jira/browse/SPARK-4537). Adding total received records and processed records metrics back to UI.  Author: jerryshao <[email protected]> Closes #3852 from jerryshao/SPARK-5028 and squashes the following commits: c8c4877 [jerryshao] Add total received and processed metrics to Streaming UI (cherry picked from commit fdc2aa4918fd4c510f04812b782cc0bfef9a2107) Signed-off-by: Tathagata Das <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/14dbd831 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/14dbd831 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/14dbd831 Branch: refs/heads/branch-1.2 Commit: 14dbd8312b107a95fb65f0b0d24d0a6bf3a05d87 Parents: bd70ff9 Author: jerryshao <[email protected]> Authored: Wed Dec 31 14:45:31 2014 -0800 Committer: Tathagata Das <[email protected]> Committed: Wed Dec 31 14:45:51 2014 -0800 ---------------------------------------------------------------------- .../scala/org/apache/spark/streaming/ui/StreamingPage.scala | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/14dbd831/streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingPage.scala ---------------------------------------------------------------------- diff --git a/streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingPage.scala b/streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingPage.scala index 1353e48..98e9a2e 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingPage.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingPage.scala @@ -67,6 +67,12 @@ private[ui] class StreamingPage(parent: StreamingTab) <li> <strong>Waiting batches: </strong>{listener.numUnprocessedBatches} </li> + <li> + <strong>Received records: </strong>{listener.numTotalReceivedRecords} + </li> + <li> + <strong>Processed records: </strong>{listener.numTotalProcessedRecords} + </li> </ul> } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
