You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by al...@apache.org on 2017/03/01 17:01:29 UTC
[2/2] beam git commit: This closes #2127
This closes #2127
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/79b1395c
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/79b1395c
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/79b1395c
Branch: refs/heads/master
Commit: 79b1395c25e23bf7ff3946cf9ffd2c01b048d722
Parents: d66029c 6e9f7ad
Author: Aljoscha Krettek <al...@gmail.com>
Authored: Wed Mar 1 18:01:06 2017 +0100
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Wed Mar 1 18:01:06 2017 +0100
----------------------------------------------------------------------
.../apache/beam/runners/core/DoFnRunners.java | 39 +++
.../beam/runners/core/StatefulDoFnRunner.java | 233 +++++++++++++++++
.../runners/core/StatefulDoFnRunnerTest.java | 255 +++++++++++++++++++
.../wrappers/streaming/DoFnOperator.java | 4 +
4 files changed, 531 insertions(+)
----------------------------------------------------------------------