This closes #4057: [BEAM-3035] Extract ReifyTimestampsAndWindows
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0df7ba9d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0df7ba9d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/0df7ba9d Branch: refs/heads/tez-runner Commit: 0df7ba9d6791bf06a59e3e7d0cb9500bbaa2b1ee Parents: 40100db 7966b75 Author: Eugene Kirpichov <[email protected]> Authored: Thu Nov 16 14:57:56 2017 -0800 Committer: Eugene Kirpichov <[email protected]> Committed: Thu Nov 16 14:57:56 2017 -0800 ---------------------------------------------------------------------- .../examples/complete/AutoCompleteTest.java | 20 +- .../apache/beam/sdk/testing/GatherAllPanes.java | 15 +- .../org/apache/beam/sdk/transforms/Reify.java | 192 +++++++++++++++++ .../beam/sdk/transforms/ReifyTimestamps.java | 55 +++-- .../apache/beam/sdk/transforms/Reshuffle.java | 2 +- .../apache/beam/sdk/transforms/ReifyTest.java | 212 +++++++++++++++++++ .../beam/sdk/transforms/ReshuffleTest.java | 4 +- .../beam/sdk/transforms/SplittableDoFnTest.java | 9 +- .../apache/beam/sdk/transforms/WatchTest.java | 2 +- 9 files changed, 447 insertions(+), 64 deletions(-) ----------------------------------------------------------------------
