Commit 75d1b5d

committed

Switch streaming engine worker harness based on job settings

1 parent a6f63ac commit 75d1b5dCopy full SHA for 75d1b5d

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)