You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by lc...@apache.org on 2020/08/21 21:09:12 UTC

[beam] branch master updated (3d0f7dc -> 60c1e8d)

This is an automated email from the ASF dual-hosted git repository.

lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 3d0f7dc  Merge pull request #12665 from [BEAM-10771] Added Whitespacelint job to pull request template
     add 60c1e8d  [BEAM-10703] Prepare Dataflow Java runner for shardable states (#12578)

No new revisions were added by this update.

Summary of changes:
 .../worker/MetricTrackingWindmillServerStub.java   |  21 +-
 .../beam/runners/dataflow/worker/ReaderCache.java  |  48 +++--
 .../dataflow/worker/StreamingDataflowWorker.java   | 101 ++++++----
 .../worker/StreamingModeExecutionContext.java      |  22 ++-
 .../dataflow/worker/WindmillStateCache.java        |  57 ++++--
 .../runners/dataflow/worker/ReaderCacheTest.java   |  46 +++--
 .../worker/StreamingDataflowWorkerTest.java        | 213 +++++++++++++++++----
 .../dataflow/worker/WindmillStateCacheTest.java    | 136 ++++++++++---
 .../worker/WindmillStateInternalsTest.java         |   9 +-
 .../worker/windmill/src/main/proto/windmill.proto  |   1 +
 10 files changed, 497 insertions(+), 157 deletions(-)