WriteJobStatsTracker¶

WriteJobStatsTracker is an abstraction of write job statistics trackers.

WriteJobStatsTracker is a Serializable.

Contract¶

Creating WriteTaskStatsTracker¶

newTaskInstance(): WriteTaskStatsTracker

Creates a new WriteTaskStatsTracker

See:

• BasicWriteJobStatsTracker

Used when:

• FileFormatDataWriter is created

Processing Write Job Statistics¶

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

See:

• BasicWriteJobStatsTracker

Used when:

• FileFormatWriter utility is used to process the statistics (of a write job)

Implementations¶

• BasicWriteJobStatsTracker