[#31438] Trigger Precusor work for Prism. (#33763)
* [prism] Never mix Data and timers in the same bundle. No execution order guarantees.
* Trigger State machine - no processing time - no merging.
* comments
* fix aftereach Handling to proceed only on finished
* Add default + fix OrFinally
* Split the isReady into onElement, shouldFire, and onFire methods.
* Add string prints, adjust OnWindowExp behavior.
* Add tests for unset AfterEndOfWindow subtriggers & fixes.
---------
Co-authored-by:
lostluck <13907733+lostluck@users.noreply.github.com>
显示
- sdks/go/pkg/beam/runners/prism/internal/engine/data.go 18 个添加, 1 个删除sdks/go/pkg/beam/runners/prism/internal/engine/data.go
- sdks/go/pkg/beam/runners/prism/internal/engine/elementmanager.go 18 个添加, 2 个删除.../pkg/beam/runners/prism/internal/engine/elementmanager.go
- sdks/go/pkg/beam/runners/prism/internal/engine/strategy.go 538 个添加, 1 个删除sdks/go/pkg/beam/runners/prism/internal/engine/strategy.go
- sdks/go/pkg/beam/runners/prism/internal/engine/strategy_test.go 388 个添加, 0 个删除...o/pkg/beam/runners/prism/internal/engine/strategy_test.go
- sdks/go/pkg/beam/runners/prism/internal/execute.go 6 个添加, 1 个删除sdks/go/pkg/beam/runners/prism/internal/execute.go
加载中