WriteJobStatsTracker¶
WriteJobStatsTracker
is the <
[[contract]] .WriteJobStatsTracker Contract [cols="1m,2",options="header",width="100%"] |=== | Method | Description
| newTaskInstance a| [[newTaskInstance]]
[source, scala]¶
newTaskInstance(): WriteTaskStatsTracker¶
Creates a new <
Used when EmptyDirectoryWriteTask
, SingleDirectoryWriteTask
and DynamicPartitionWriteTask
are requested for the statsTrackers
| processStats a| [[processStats]]
[source, scala]¶
processStats(stats: Seq[WriteTaskStats]): Unit¶
Used when...FIXME |===
[[implementations]] NOTE: BasicWriteJobStatsTracker is the one and only known implementation of the <
Last update: 2020-11-29