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 2017/09/11 22:00:37 UTC

[2/2] beam git commit: [BEAM-2862] Add PTransform overrides specific to execution of StatefulDoFns over the Fn API using the DataflowRunner.

[BEAM-2862] Add PTransform overrides specific to execution of StatefulDoFns over the Fn API using the DataflowRunner.

This closes #3832


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/774b2681
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/774b2681
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/774b2681

Branch: refs/heads/master
Commit: 774b26819029b2ad316e2479bc6e0dcf3d17eef1
Parents: 5a995e6 97806e3
Author: Luke Cwik <lc...@google.com>
Authored: Mon Sep 11 15:00:24 2017 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Mon Sep 11 15:00:24 2017 -0700

----------------------------------------------------------------------
 .../dataflow/BatchStatefulParDoOverrides.java   | 71 +++++++++++++++++---
 .../beam/runners/dataflow/DataflowRunner.java   |  4 +-
 .../BatchStatefulParDoOverridesTest.java        | 45 ++++++++++++-
 3 files changed, 106 insertions(+), 14 deletions(-)
----------------------------------------------------------------------