spark-core-ElementTrackingStore.adoc

ElementTrackingStore

ElementTrackingStore is a KVStore that…​FIXME

ElementTrackingStore is created when…​FIXME

Table 1. ElementTrackingStore’s Internal Properties (e.g. Registries, Counters and Flags)

Name	Description
triggers	Triggers per class Used when…​FIXME
flushTriggers	Functions that…​FIXME Used when…​FIXME
executor	Java ExecutorService that…​FIXME Used when…​FIXME
stopped	stopped flag to control…​FIXME Used when…​FIXME

write Method

write(value: Any, checkTriggers: Boolean): Unit

Note	write is part of HERE Contract to…​FIXME.

write…​FIXME

Note	write is used when…​FIXME

Trigger

Trigger is…​FIXME

Creating ElementTrackingStore Instance

ElementTrackingStore takes the following when created:

• KVStore

• SparkConf

ElementTrackingStore initializes the internal registries and counters.