Make SimplePCollectionView Visible View will be replaced as a marker interface. Runners can expect to always recieve a subclass of SimplePCollectionView, and cast to it when methods are required.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e8f28dd4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e8f28dd4 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e8f28dd4 Branch: refs/heads/master Commit: e8f28dd477c2404ebfd26d08b87340a7eea6525c Parents: 781c155 Author: Thomas Groh <[email protected]> Authored: Fri Apr 21 09:46:28 2017 -0700 Committer: Thomas Groh <[email protected]> Committed: Fri Apr 21 19:01:01 2017 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/beam/sdk/util/PCollectionViews.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/e8f28dd4/sdks/java/core/src/main/java/org/apache/beam/sdk/util/PCollectionViews.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/util/PCollectionViews.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/util/PCollectionViews.java index 14b36fd..f2052ac 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/util/PCollectionViews.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/util/PCollectionViews.java @@ -341,8 +341,10 @@ public class PCollectionViews { /** * A class for {@link PCollectionView} implementations, with additional type parameters * that are not visible at pipeline assembly time when the view is used as a side input. + * + * <p>For internal use only. */ - private static class SimplePCollectionView<ElemT, ViewT, W extends BoundedWindow> + public static class SimplePCollectionView<ElemT, ViewT, W extends BoundedWindow> extends PValueBase implements PCollectionView<ViewT> { /** The {@link PCollection} this view was originally created from. */
