StreamingQueryStatusStore¶

Creating Instance¶

StreamingQueryStatusStore takes the following to be created:

• KVStore (Spark Core)

StreamingQueryStatusStore is created when:

• StreamingQueryHistoryServerPlugin is requested to setupUI
• SharedState (Spark SQL) is created (with spark.sql.streaming.ui.enabled enabled)

allQueryUIData¶

allQueryUIData: Seq[StreamingQueryUIData]

allQueryUIData creates a view of StreamingQueryDatas (in the KVStore) indexed by startTimestamp to makeUIData.

allQueryUIData is used when:

• StreamingQueryHistoryServerPlugin is requested to setupUI
• StreamingQueryPage is requested to generateStreamingQueryTable
• StreamingQueryStatisticsPage is requested to render

makeUIData¶

makeUIData(
  summary: StreamingQueryData): StreamingQueryUIData

makeUIData...FIXME