[Prism]Support after_processing_time trigger#36069

Closed

shunping wants to merge 14 commits into

apache:masterfrom

shunping:prism-after-processing-time-trigger

Commits on Sep 5, 2025

Commits on Sep 6, 2025

Some minor fix.
shunping
committed
Rename buildTriggeredBundle to runTriggeredBundle. Rearrange the code for refactoring.
shunping
committed
Split runTriggeredBundle into three parts, following the pattern of EventTimeBundle and ProcessingTimeBundle.
shunping
committed

Commits on Sep 7, 2025

Retrieve after processing time triggers and set processing time timers accordingly.
shunping
committed
Add buildProcessingTimeBundle to stageKind. Move part of the startProcessingTimeBundle into the build function for stagefulStageKind.
shunping
committed

Commits on Sep 8, 2025

Attempt to implement buildProcessingTimeBundle for aggregateKind.
shunping
committed

Commits on Sep 10, 2025