Repository: beam Updated Branches: refs/heads/master a991c9d85 -> e70e608da
This closes #2025 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e70e608d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e70e608d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e70e608d Branch: refs/heads/master Commit: e70e608da14c2f70899b37bb127a01debc54a96b Parents: a991c9d f0665e9 Author: Thomas Groh <tg...@google.com> Authored: Tue Feb 21 09:35:21 2017 -0800 Committer: Thomas Groh <tg...@google.com> Committed: Tue Feb 21 09:35:21 2017 -0800 ---------------------------------------------------------------------- .../runners/dataflow/BatchViewOverrides.java | 1391 +++++++++++++++ .../dataflow/DataflowPipelineTranslator.java | 2 +- .../beam/runners/dataflow/DataflowRunner.java | 1677 +----------------- .../dataflow/StreamingViewOverrides.java | 353 ++++ .../dataflow/BatchViewOverridesTest.java | 633 +++++++ .../runners/dataflow/DataflowRunnerTest.java | 480 ----- 6 files changed, 2392 insertions(+), 2144 deletions(-) ----------------------------------------------------------------------
