Fix/Refactor GetData interfaces for Direct Path integration (#31784)

* add getdata clients and shareable logic for GetData w/ throttling and metric tracking. * add HeartbeatSender interface * move side input state API into Work instance w/ keyed state fetching. Future proofs this logic for direct path.
apache · Jul 30, 2024 · 570f2f8 · 570f2f8
1 parent 98f8b86
commit 570f2f8
Show file tree

Hide file tree

Showing 65 changed files with 2,255 additions and 1,108 deletions.
diff --git a/...c/main/java/org/apache/beam/runners/dataflow/worker/MetricTrackingWindmillServerStub.java b/...c/main/java/org/apache/beam/runners/dataflow/worker/MetricTrackingWindmillServerStub.java