You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/11/22 20:11:06 UTC
[02/50] incubator-beam git commit: Reduce Visibility of
PCollectionViewWriter
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/python-sdk
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);
}