beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [5/5] incubator-beam git commit: This closes #1612: [BEAM-27] Support timer setting and receiving in SimpleDoFnRunner
Date Sat, 17 Dec 2016 21:11:36 GMT
This closes #1612: [BEAM-27] Support timer setting and receiving in SimpleDoFnRunner

  Use empty SideInputReader, fixes NPE in SimpleDoFnRunnerTest
  Test that SimpleDoFnRunner wraps exceptions in startBundle and finishBundle
  Add timer support to DoFnRunner(s)
  Make TimerSpec and StateSpec fields accessible


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

Branch: refs/heads/master
Commit: c28957d16fb0f63f82f578cf904df61bf7bb63e5
Parents: 5255a33 b78aa66
Author: Kenneth Knowles <klk@google.com>
Authored: Sat Dec 17 12:59:25 2016 -0800
Committer: Kenneth Knowles <klk@google.com>
Committed: Sat Dec 17 12:59:25 2016 -0800

----------------------------------------------------------------------
 .../apache/beam/runners/core/DoFnRunner.java    |   9 +
 .../core/LateDataDroppingDoFnRunner.java        |   7 +
 .../core/PushbackSideInputDoFnRunner.java       |   8 +
 .../beam/runners/core/SimpleDoFnRunner.java     | 236 ++++++++++++++-
 .../beam/runners/core/SimpleOldDoFnRunner.java  |   8 +
 .../core/PushbackSideInputDoFnRunnerTest.java   |  41 +++
 .../beam/runners/core/SimpleDoFnRunnerTest.java | 301 +++++++++++++++++++
 .../sdk/transforms/reflect/DoFnSignatures.java  |   4 +
 8 files changed, 613 insertions(+), 1 deletion(-)
----------------------------------------------------------------------



Mime
View raw message