This closes #2264
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7c7bb820 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7c7bb820 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7c7bb820 Branch: refs/heads/master Commit: 7c7bb82096df53603f2885db4efd09560e71a60f Parents: c31b633 9f970fa Author: Thomas Groh <[email protected]> Authored: Wed Mar 22 14:04:13 2017 -0700 Committer: Thomas Groh <[email protected]> Committed: Wed Mar 22 14:04:13 2017 -0700 ---------------------------------------------------------------------- .../beam/runners/core/SimpleDoFnRunner.java | 6 +- .../beam/runners/core/SimpleDoFnRunnerTest.java | 146 +++++++++++++++++++ .../org/apache/beam/sdk/transforms/DoFn.java | 19 ++- .../beam/sdk/transforms/WithTimestamps.java | 26 +++- .../apache/beam/sdk/transforms/ParDoTest.java | 112 ++++++++++---- .../beam/sdk/io/mongodb/MongoDbGridFSIO.java | 1 + 6 files changed, 272 insertions(+), 38 deletions(-) ----------------------------------------------------------------------
