This is an automated email from the ASF dual-hosted git repository.
scwhittle pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 2ae4a28e6fc Force downgrade mpmath to avoid test breakages (#30418)
add 6c3e8ad1af1 [Dataflow Streaming] Start to refactor persistence layer
to prepare for direct path (#30265)
No new revisions were added by this update.
Summary of changes:
.../dataflow/worker/StreamingDataflowWorker.java | 278 ++++++++++++---------
.../streaming/sideinput/SideInputStateFetcher.java | 23 +-
.../worker/windmill/state/WindmillStateReader.java | 31 +--
.../worker/StreamingDataflowWorkerTest.java | 6 +-
.../sideinput/SideInputStateFetcherTest.java | 14 +-
.../windmill/state/WindmillStateReaderTest.java | 8 +-
6 files changed, 195 insertions(+), 165 deletions(-)
