Commit b5957d0

committed

Switch streaming engine worker harness based on job settings

1 parent 757ffcd commit b5957d0Copy full SHA for b5957d0

5 files changed

runners/google-cloud-dataflow-java/worker
- src
  - main/java/org/apache/beam/runners/dataflow/worker
    - StreamingDataflowWorker.java
    - streaming/harness
      - SingleSourceWorkerHarness.java
      - StreamingWorkerStatusPages.java
  - test/java/org/apache/beam/runners/dataflow/worker
    - StreamingDataflowWorkerTest.java
- windmill/src/main/proto
  - windmill.proto

Comments

(0)