Module compaction

Source

Enumsยง

CompactionWindow

Constantsยง

DEFAULT_LOGICAL_COMPACTION_WINDOW_DURATION
DEFAULT_LOGICAL_COMPACTION_WINDOW_MILLIS ๐Ÿ”’
DEFAULT_LOGICAL_COMPACTION_WINDOW, in milliseconds. The default is set to a second to track the default timestamp frequency for sources.
DEFAULT_LOGICAL_COMPACTION_WINDOW_TS ๐Ÿ”’
DEFAULT_LOGICAL_COMPACTION_WINDOW as an EpochMillis timestamp.
SINCE_GRANULARITY
The value to round all since frontiers to. We pick 1s somewhat arbitrarily, but matching historical practice.