Commit fe71ab1
authored
Add ordered window elements into example folder (#36575)
* Add an example for OrderedBatchElements.
* Fix lints.
* Skip the test if go is not installed in the runtime.
* Skip tests in windows correctly.
* Fix windows test failure.
* Refactor the code and make it extensible to different states in the future.
* Revert the change on prism_runner.py
* Add bag state as the buffer state type.
* Add value state as buffer state.
* Fix lints
* Fix lints.
* Add TestStream method to generate input source to reduce test flakiness.
* Re-enable a test condition.1 parent 6dedf8f commit fe71ab1
File tree
3 files changed
+1000
-0
lines changed- sdks/python/apache_beam/examples/cookbook/ordered_window_elements
3 files changed
+1000
-0
lines changedLines changed: 16 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
0 commit comments