Closes #862
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/268ec11c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/268ec11c Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/268ec11c Branch: refs/heads/master Commit: 268ec11c62f0803e2eef5c5f1715b270d261c3a6 Parents: f657956 0d3f2f2 Author: bchambers <bchamb...@google.com> Authored: Thu Sep 1 13:16:47 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Thu Sep 1 13:16:47 2016 -0700 ---------------------------------------------------------------------- .../apache/beam/sdk/coders/NullableCoder.java | 7 + .../apache/beam/sdk/transforms/DoFnTester.java | 33 ++- .../org/apache/beam/sdk/transforms/Latest.java | 203 ++++++++++++++++ .../beam/sdk/values/TimestampedValue.java | 14 ++ .../beam/sdk/transforms/DoFnTesterTest.java | 34 ++- .../beam/sdk/transforms/LatestFnTests.java | 233 +++++++++++++++++++ .../apache/beam/sdk/transforms/LatestTest.java | 146 ++++++++++++ .../beam/sdk/values/TimestampedValueTest.java | 83 +++++++ 8 files changed, 747 insertions(+), 6 deletions(-) ----------------------------------------------------------------------