beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lc...@apache.org
Subject [2/2] beam git commit: [BEAM-2862] Add PTransform overrides specific to execution of StatefulDoFns over the Fn API using the DataflowRunner.
Date Mon, 11 Sep 2017 22:00:37 GMT
[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 <lcwik@google.com>
Authored: Mon Sep 11 15:00:24 2017 -0700
Committer: Luke Cwik <lcwik@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(-)
----------------------------------------------------------------------



Mime
View raw message