HeartSaVioR commented on a change in pull request #26201: [SPARK-29543][SS][UI]
Init structured streaming ui
URL: https://github.com/apache/spark/pull/26201#discussion_r350010786
##########
File path:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ProgressReporter.scala
##########
@@ -345,3 +353,35 @@ trait ProgressReporter extends Logging {
currentStatus = currentStatus.copy(message = message)
}
}
+
+/**
+ * A summary information of the streaming query.
+ */
+class QuerySummary {
Review comment:
Looks like this class is always referenced with
`QuerySummary.TOTAL_INPUT_RECORDS` (I meant single value), instead of looping
and accessing available values. That makes me feel that it should be much
simpler to just expose methods to get/update "total input records". At least
for now, this seems overkill, as callers are not flexible to handle multiple
values for summary.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
