ProtectedconstructorStaticInstanceEvaluates watermarks for a batch of records. Returns a map of RecordID -> WatermarkDecision. A run that overwrites
human values skips nothing. Without SkipUnchanged no record is skipped, but under Checksum each record carries
its basis hash, so its watermark is refreshed once it succeeds (RefreshDecisions).
Optionaloptions: { excludeFields?: string[] }Computes the basis hash for a record. Delegates to processor.ComputeBasisHash if available, otherwise falls back to BaseEntity.ComputeContentHash() or ComputeContentHashAsync on record data.
Optionaloptions: { excludeFields?: string[] }The Global Object Store is a place to store global objects that need to be shared across the application. Depending on the execution environment, this could be the window object in a browser, or the global object in a node environment, or something else in other contexts. The key here is that in some cases static variables are not truly shared because it is possible that a given class might have copies of its code in multiple paths in a deployed application. This approach ensures that no matter how many code copies might exist, there is only one instance of the object in question by using the Global Object Store.
ProtectedProcessorThe context the processor gets for the batch check, built from the parameters.
The batch check's parameters.
ProtectedRefreshThe decisions of a run that skips nothing (e.g. a version backfill): each record whose processor computes a basis
hash carries it and its loaded watermark, so the next SkipUnchanged run can skip it. Only the processor's own
ComputeBasisHash counts, not the record-content fallback.
The batch check's parameters (SkipUnchanged off, strategy Checksum).
Upserts a watermark row for a record on success.
Protected StaticgetReturns the singleton instance of the class. If the instance does not exist, it is created and stored in the Global Object Store. If className is provided it will be used as part of the key in the Global Object Store, otherwise the actual class name will be used. NOTE: the class name used by default is the lowest level of the object hierarchy, so if you have a class that extends another class, the lowest level class name will be used.
OptionalclassName: stringProtected StaticProcessA "process, nothing to refresh" decision for every record.
The batch's records.
Service managing record-level watermarking and change detection.