This closes #520
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5049011a Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5049011a Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/5049011a Branch: refs/heads/master Commit: 5049011a2602acc1ce0e1997b467ddee38c66c10 Parents: d60a0a0 c376b45 Author: Kenneth Knowles <[email protected]> Authored: Mon Aug 8 13:51:21 2016 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Mon Aug 8 13:51:21 2016 -0700 ---------------------------------------------------------------------- .../beam/runners/direct/SideInputContainer.java | 2 +- .../runners/direct/ViewEvaluatorFactory.java | 5 +- .../functions/FlinkProcessContext.java | 2 +- .../functions/SideInputInitializer.java | 2 +- .../spark/translation/SparkProcessContext.java | 2 +- .../apache/beam/sdk/transforms/DoFnTester.java | 2 +- .../org/apache/beam/sdk/transforms/ViewFn.java | 45 ++++ .../beam/sdk/util/DirectSideInputReader.java | 4 +- .../apache/beam/sdk/util/PCollectionViews.java | 228 +++++++++++++------ .../apache/beam/sdk/values/PCollectionView.java | 29 ++- .../sdk/testing/PCollectionViewTesting.java | 35 +-- 11 files changed, 262 insertions(+), 94 deletions(-) ----------------------------------------------------------------------
