spark技术分享LiveEntity
|
1 2 3 4 5 6 7 8 9 10 11 |
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.
|
| Method | Description |
|---|---|
|
|
Used exclusivey when |
LiveEntity tracks the last write time (in lastWriteTime internal registry).
write Method
|
1 2 3 4 5 |
write(store: ElementTrackingStore, now: Long, checkTriggers: Boolean = false): Unit |
In the end, write records the time in the lastWriteTime.
|
Note
|
|
