beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lc...@apache.org
Subject [1/2] beam git commit: Mark More values methods Internal
Date Fri, 12 May 2017 01:38:24 GMT
Repository: beam
Updated Branches:
  refs/heads/release-2.0.0 905ebccf2 -> a955b24b4


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/1813a2e0
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1813a2e0
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1813a2e0

Branch: refs/heads/release-2.0.0
Commit: 1813a2e0bd4efb733ead0437fac276643660116e
Parents: 905ebcc
Author: Thomas Groh <tgroh@google.com>
Authored: Thu May 11 16:17:54 2017 -0700
Committer: Luke Cwik <lcwik@google.com>
Committed: Thu May 11 18:37:18 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/1813a2e0/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/1813a2e0/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);


Mime
View raw message