Commit ee02db8
authored
[Iceberg AddFiles] Use thread pool to process incoming datafiles (#38018)
* use thread pool to process incoming datafiles
* trigger ITs
* add drain logic if too many files in queue; synchronize table
* compile fix
* fix tests
* fix tests1 parent 24f02bb commit ee02db8
4 files changed
Lines changed: 273 additions & 101 deletions
File tree
- .github/trigger_files
- sdks/java/io/iceberg/src
- main/java/org/apache/beam/sdk/io/iceberg
- test/java/org/apache/beam/sdk/io/iceberg
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | 2 | | |
3 | | - | |
| 3 | + | |
4 | 4 | | |
0 commit comments