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/gearpump-runner Commit: c28957d16fb0f63f82f578cf904df61bf7bb63e5 Parents: 5255a33 b78aa66 Author: Kenneth Knowles <k...@google.com> Authored: Sat Dec 17 12:59:25 2016 -0800 Committer: Kenneth Knowles <k...@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(-) ----------------------------------------------------------------------
