Repository: beam Updated Branches: refs/heads/master ff6bb3530 -> f43b61af4
Annotate internal methods of PCollection Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f4dfbb20 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f4dfbb20 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f4dfbb20 Branch: refs/heads/master Commit: f4dfbb206382d3ea73881727aa8b0f74eaf98ef4 Parents: ff6bb35 Author: Kenneth Knowles <[email protected]> Authored: Tue May 2 19:31:22 2017 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Thu May 4 06:09:29 2017 -0700 ---------------------------------------------------------------------- .../org/apache/beam/sdk/values/PCollection.java | 16 +++++++--------- 1 file changed, 7 insertions(+), 9 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/f4dfbb20/sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollection.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollection.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollection.java index 034f0de..20e5d68 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollection.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollection.java @@ -22,6 +22,7 @@ import static com.google.common.base.Preconditions.checkState; import javax.annotation.Nullable; import org.apache.beam.sdk.Pipeline; +import org.apache.beam.sdk.annotations.Internal; import org.apache.beam.sdk.coders.CannotProvideCoderException; import org.apache.beam.sdk.coders.CannotProvideCoderException.ReasonCode; import org.apache.beam.sdk.coders.Coder; @@ -330,30 +331,27 @@ public class PCollection<T> extends PValueBase implements PValue { } /** - * Sets the {@link WindowingStrategy} of this {@link PCollection}. - * - * <p>For use by primitive transformations only. + * <b><i>For internal use only; no backwards-compatibility guarantees.</i></b> */ + @Internal public PCollection<T> setWindowingStrategyInternal(WindowingStrategy<?, ?> windowingStrategy) { this.windowingStrategy = windowingStrategy; return this; } /** - * Sets the {@link PCollection.IsBounded} of this {@link PCollection}. - * - * <p>For use by internal transformations only. + * <b><i>For internal use only; no backwards-compatibility guarantees.</i></b> */ + @Internal public PCollection<T> setIsBoundedInternal(IsBounded isBounded) { this.isBounded = isBounded; return this; } /** - * Creates and returns a new {@link PCollection} for a primitive output. - * - * <p>For use by primitive transformations only. + * <b><i>For internal use only; no backwards-compatibility guarantees.</i></b> */ + @Internal public static <T> PCollection<T> createPrimitiveOutputInternal( Pipeline pipeline, WindowingStrategy<?, ?> windowingStrategy,
