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);