EventTimeStats¶

EventTimeStats is used to help calculate event-time column statistics (statistics of the values of an event-time column):

• Maximum
• Minimum
• Average
• Count

EventTimeStats is used by EventTimeStatsAccum accumulator.

Zero Value¶

EventTimeStats defines a special value zero with the following values:

• Long.MinValue for the max
• Long.MaxValue for the min
• 0.0 for the avg
• 0L for the count

Adding Event-Time Value¶

add(
  eventTime: Long): Unit

add updates the statistics given the eventTime value.

Merging EventTimeStats¶

merge(
  that: EventTimeStats): Unit

merge...FIXME