StreamingQueryPage¶

StreamingQueryPage is a WebUIPage (Spark Core) that renders the following sections as Streaming Query:

• Active Streaming Queries
• Completed Streaming Queries

Creating Instance¶

StreamingQueryPage takes the following to be created:

• Parent StreamingQueryTab

StreamingQueryPage is created when:

• StreamingQueryTab is created (and attaches this and StreamingQueryStatisticsPage pages)

Active Streaming Queries¶

Completed Streaming Queries¶

Avg Input /sec¶

Total of inputRowsPerSeconds of all StreamingQueryProgresses by their number

Rendering Page¶

render(
  request: HttpServletRequest): Seq[Node]

render is part of the WebUIPage (Spark Core) abstraction.

render renders an HTML page with Streaming Query title and generateStreamingQueryTable.

generateStreamingQueryTable¶

generateStreamingQueryTable(
  request: HttpServletRequest): Seq[Node]

generateStreamingQueryTable requests the StreamingQueryStatusStore for allQueryUIData that is split into active and inactive queries.

generateStreamingQueryTable renders Active Streaming Queries section for the active streaming queries.

generateStreamingQueryTable renders Completed Streaming Queries section for the inactive (completed) streaming queries.