Skip to content

WriteJobStatsTracker

WriteJobStatsTracker is an abstraction of write job statistics trackers.

WriteJobStatsTracker is a Serializable.

Contract

Creating WriteTaskStatsTracker

newTaskInstance(): WriteTaskStatsTracker

Creates a new WriteTaskStatsTracker

Used when:

Processing Write Job Statistics

processStats(
  stats: Seq[WriteTaskStats],
  jobCommitTime: Long): Unit

Used when:

Implementations