Commit b30af9e
BatchElements transform for Java SDK (#38369)
* skeleton
* calculate batch size
* global window batching
* window awae batching
* unit tests
* java api docs
* gemini comments
* checkstyle
* fix spotbug
* update doc and changes.md
* checkstyle
* whitespace
---------
Co-authored-by: Ganeshsivakumar <ganeshsivakumar85@gmail.com>1 parent e9a2b60 commit b30af9e
3 files changed
Lines changed: 1201 additions & 1 deletion
File tree
- sdks/java/core/src
- main/java/org/apache/beam/sdk/transforms
- test/java/org/apache/beam/sdk/transforms
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
77 | 77 | | |
78 | 78 | | |
79 | 79 | | |
| 80 | + | |
80 | 81 | | |
81 | 82 | | |
82 | 83 | | |
| |||
2435 | 2436 | | |
2436 | 2437 | | |
2437 | 2438 | | |
2438 | | - | |
| 2439 | + | |
0 commit comments