Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 8C2BF200CA9 for ; Fri, 12 May 2017 03:38:26 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 89C34160BC7; Fri, 12 May 2017 01:38:26 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id D89BC160BCA for ; Fri, 12 May 2017 03:38:25 +0200 (CEST) Received: (qmail 37086 invoked by uid 500); 12 May 2017 01:38:25 -0000 Mailing-List: contact commits-help@beam.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@beam.apache.org Delivered-To: mailing list commits@beam.apache.org Received: (qmail 36955 invoked by uid 99); 12 May 2017 01:38:24 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 12 May 2017 01:38:24 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id C4EB0DFD70; Fri, 12 May 2017 01:38:24 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: lcwik@apache.org To: commits@beam.apache.org Date: Fri, 12 May 2017 01:38:24 -0000 Message-Id: <1dd883913ce4445284a97c5d76878944@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [1/2] beam git commit: Mark More values methods Internal archived-at: Fri, 12 May 2017 01:38:26 -0000 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 Authored: Thu May 11 16:17:54 2017 -0700 Committer: Luke Cwik 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 + * For internal use only; no backwards-compatibility guarantees. + * + *

Returns a {@link PCollectionTuple} with each of the given tags mapping to a new * output {@link PCollection}. * *

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}. + * For internal use only; no backwards-compatibility guarantees. + * + *

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