WriteJobStatsTracker

WriteJobStatsTracker is the abstraction of WriteJobStatsTrackers that can create a new WriteTaskStatsTracker and processStats.

Table 1. WriteJobStatsTracker Contract
Method Description

newTaskInstance

 
newTaskInstance(): WriteTaskStatsTracker

Creates a new WriteTaskStatsTracker

Used when EmptyDirectoryWriteTask, SingleDirectoryWriteTask and DynamicPartitionWriteTask are requested for the statsTrackers

processStats

 
processStats(stats: Seq[WriteTaskStats]): Unit

Used when…​FIXME
Note
 BasicWriteJobStatsTracker is the one and only known implementation of the WriteJobStatsTracker Contract in Apache Spark.

results matching ""

    No results matching ""