You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2017/05/12 01:34:25 UTC
[1/2] beam git commit: Mark More values methods Internal
Repository: beam
Updated Branches:
refs/heads/master 36a6cd69a -> d6ac39a23
Mark More values methods Internal
PCollectionTuple#ofPrimitiveOutputsInternal is internal.
TaggedPValue is internal.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/db7d71ae
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/db7d71ae
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/db7d71ae
Branch: refs/heads/master
Commit: db7d71aec5d6c4b7a15474c7ef9db28460fb0043
Parents: 36a6cd6
Author: Thomas Groh <tg...@google.com>
Authored: Thu May 11 16:17:54 2017 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Thu May 11 18:33:39 2017 -0700
----------------------------------------------------------------------
.../main/java/org/apache/beam/sdk/values/PCollectionTuple.java | 6 +++++-
.../src/main/java/org/apache/beam/sdk/values/TaggedPValue.java | 6 +++++-
2 files changed, 10 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/db7d71ae/sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollectionTuple.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollectionTuple.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollectionTuple.java
index d1bb6d7..793994f 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollectionTuple.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollectionTuple.java
@@ -23,6 +23,7 @@ import java.util.LinkedHashMap;
import java.util.Map;
import java.util.Objects;
import org.apache.beam.sdk.Pipeline;
+import org.apache.beam.sdk.annotations.Internal;
import org.apache.beam.sdk.transforms.PTransform;
import org.apache.beam.sdk.transforms.ParDo;
import org.apache.beam.sdk.values.PCollection.IsBounded;
@@ -189,11 +190,14 @@ public class PCollectionTuple implements PInput, POutput {
}
/**
- * Returns a {@link PCollectionTuple} with each of the given tags mapping to a new
+ * <b><i>For internal use only; no backwards-compatibility guarantees.</i></b>
+ *
+ * <p>Returns a {@link PCollectionTuple} with each of the given tags mapping to a new
* output {@link PCollection}.
*
* <p>For use by primitive transformations only.
*/
+ @Internal
public static PCollectionTuple ofPrimitiveOutputsInternal(
Pipeline pipeline,
TupleTagList outputTags,
http://git-wip-us.apache.org/repos/asf/beam/blob/db7d71ae/sdks/java/core/src/main/java/org/apache/beam/sdk/values/TaggedPValue.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/values/TaggedPValue.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/values/TaggedPValue.java
index 3b4d599..c1e0209 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/values/TaggedPValue.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/values/TaggedPValue.java
@@ -21,11 +21,15 @@ package org.apache.beam.sdk.values;
import com.google.auto.value.AutoValue;
import com.google.common.collect.Iterables;
+import org.apache.beam.sdk.annotations.Internal;
/**
- * A (TupleTag, PValue) pair used in the expansion of a {@link PInput} or {@link POutput}.
+ * <b><i>For internal use only; no backwards-compatibility guarantees.</i></b>
+ *
+ * <p>A (TupleTag, PValue) pair used in the expansion of a {@link PInput} or {@link POutput}.
*/
@AutoValue
+@Internal
public abstract class TaggedPValue {
public static TaggedPValue of(TupleTag<?> tag, PValue value) {
return new AutoValue_TaggedPValue(tag, value);
[2/2] beam git commit: [BEAM-1345] Mark More values methods Internal
Posted by lc...@apache.org.
[BEAM-1345] Mark More values methods Internal
This closes #3104
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d6ac39a2
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d6ac39a2
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d6ac39a2
Branch: refs/heads/master
Commit: d6ac39a23e50e82c013e5052b48cb6ffbf929195
Parents: 36a6cd6 db7d71a
Author: Luke Cwik <lc...@google.com>
Authored: Thu May 11 18:34:15 2017 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Thu May 11 18:34:15 2017 -0700
----------------------------------------------------------------------
.../main/java/org/apache/beam/sdk/values/PCollectionTuple.java | 6 +++++-
.../src/main/java/org/apache/beam/sdk/values/TaggedPValue.java | 6 +++++-
2 files changed, 10 insertions(+), 2 deletions(-)
----------------------------------------------------------------------