diff options
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingPage.scala | 6 |
1 files changed, 6 insertions, 0 deletions
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 1353e487c7..98e9a2e639 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> } |