EventTimeStatsAccum takes the following to be created:
EventTimeStatsAccum is created when:
EventTimeWatermarkExec Physical Operator
As per design of Spark accumulators in Apache Spark, accumulator updates are automatically sent out (propagated) from tasks to the driver every heartbeat and then they are accumulated together.
AccumulatorV2 methods are called,
EventTimeStatsAccum simply relays them to the
EventTimeStats (that is responsible for event-time statistics, i.e. max, min, avg, count).
add( v: Long): Unit
add is part of the
AccumulatorV2 (Spark Core) abstraction.
add is used when EventTimeWatermarkExec physical operator is executed.