beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject [2/2] beam git commit: This closes #2127
Date Wed, 01 Mar 2017 17:01:29 GMT
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 <aljoscha.krettek@gmail.com>
Authored: Wed Mar 1 18:01:06 2017 +0100
Committer: Aljoscha Krettek <aljoscha.krettek@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(+)
----------------------------------------------------------------------



Mime
View raw message