Accumulation Mode tells the operator what to do with the state of the window when a trigger is fired. We will discuss triggers later in the section. There are three supported accumulation modes: ACCUMULATING, DISCARDING, and ACCUMULATING_AND_DISCARDING.
- ACCUMULATING: The state of the window is preserved until purged (usually as a result of window lying beyond the lateness horizon).
- DISCARDING: The state of the window is discarded immediately after firing of a trigger.
- ACCUMULATING_AND_RETRACTING: The state of the window is preserved until purged, but if the state has changed upon a trigger compared to the previous trigger, an additional retraction trigger is fired. This is to tell downstream operators to discard the previous ...