Reduce Visibility of PCollectionViewWriter This is an internal implementation detail of the DirectRunner and should not be exposed.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/bf4c504d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/bf4c504d Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/bf4c504d Branch: refs/heads/master Commit: bf4c504dffa05c8eccc5c2ae16dffdd53418a468 Parents: 5ba4d18 Author: Thomas Groh <tg...@google.com> Authored: Wed Nov 16 10:37:42 2016 -0800 Committer: Thomas Groh <tg...@google.com> Committed: Wed Nov 16 13:22:41 2016 -0800 ---------------------------------------------------------------------- .../main/java/org/apache/beam/runners/direct/DirectRunner.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/bf4c504d/runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectRunner.java ---------------------------------------------------------------------- diff --git a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectRunner.java b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectRunner.java index c9a7864..04c8eb6 100644 --- a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectRunner.java +++ b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectRunner.java @@ -183,10 +183,11 @@ public class DirectRunner /** * A {@link PCollectionViewWriter} is responsible for writing contents of a {@link PCollection} to * a storage mechanism that can be read from while constructing a {@link PCollectionView}. + * * @param <ElemT> the type of elements the input {@link PCollection} contains. * @param <ViewT> the type of the PCollectionView this writer writes to. */ - public interface PCollectionViewWriter<ElemT, ViewT> { + interface PCollectionViewWriter<ElemT, ViewT> { void add(Iterable<WindowedValue<ElemT>> values); }