Commit cd41fe9
committed
Adding a StreamingWorkerHarnessFactoryOutput class to hold harness and its dependencies
1 parent 9387cca commit cd41fe9
4 files changed
Lines changed: 242 additions & 182 deletions
File tree
- runners/google-cloud-dataflow-java
- src/main/java/org/apache/beam/runners/dataflow/options
- worker/src
- main/java/org/apache/beam/runners/dataflow/worker
- streaming/harness
- test/java/org/apache/beam/runners/dataflow/worker
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
310 | 310 | | |
311 | 311 | | |
312 | 312 | | |
313 | | - | |
| 313 | + | |
314 | 314 | | |
315 | 315 | | |
316 | 316 | | |
| |||
0 commit comments