WriteJobStatsTracker

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 ""