LiveEntity¶

LiveEntity is the <> of a live entity in Spark that...FIXME

[[contract]] [source, scala]

package org.apache.spark.status

abstract class LiveEntity { // only required methods that have no implementation // the others follow protected def doUpdate(): Any }

NOTE: LiveEntity is a private[spark] contract.

.LiveEntity Contract [cols="1,2",options="header",width="100%"] |=== | Method | Description

| doUpdate | [[doUpdate]] Used exclusivey when LiveEntity is requested to <>. |===

[[lastWriteTime]] LiveEntity tracks the last <> time (in lastWriteTime internal registry).

=== [[write]] write Method

[source, scala]¶

write(store: ElementTrackingStore, now: Long, checkTriggers: Boolean = false): Unit¶

write requests the input ElementTrackingStore to core:ElementTrackingStore.md#write[write] the <> value.

In the end, write records the time in the <>.

write is used when:

• AppStatusListener is requested to update

• SQLAppStatusListener is created (and registers a flush trigger) and requested to update