This closes #3601: Use RehydratedComponents for memoized rehydration
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f870bf51 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f870bf51 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f870bf51 Branch: refs/heads/master Commit: f870bf5164b00a1379f1e33a5ef27b3701a87c08 Parents: b6f126d 01492e6 Author: Kenneth Knowles <k...@google.com> Authored: Fri Jul 21 11:06:02 2017 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Fri Jul 21 11:06:02 2017 -0700 ---------------------------------------------------------------------- .../core/construction/CoderTranslation.java | 14 +- .../core/construction/CombineTranslation.java | 7 +- .../construction/PCollectionTranslation.java | 28 +--- .../core/construction/ParDoTranslation.java | 48 ++---- .../core/construction/RehydratedComponents.java | 158 +++++++++++++++++++ .../construction/TestStreamTranslation.java | 11 +- .../WindowingStrategyTranslation.java | 6 +- .../core/construction/CoderTranslationTest.java | 4 +- .../construction/CombineTranslationTest.java | 9 +- .../PCollectionTranslationTest.java | 12 +- .../core/construction/ParDoTranslationTest.java | 61 +++---- .../construction/RehydratedComponentsTest.java | 96 +++++++++++ .../construction/TestStreamTranslationTest.java | 11 +- .../WindowingStrategyTranslationTest.java | 5 +- .../beam/runners/dataflow/DataflowRunner.java | 16 +- 15 files changed, 355 insertions(+), 131 deletions(-) ----------------------------------------------------------------------
