Repository: beam Updated Branches: refs/heads/master 2dc61f637 -> de36e8398
Add example to BoundedCountingInput javadoc Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/65b03ebe Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/65b03ebe Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/65b03ebe Branch: refs/heads/master Commit: 65b03ebe4b9f197877af36395ed73ec2494251e6 Parents: 2dc61f6 Author: wtanaka.com <wtan...@yahoo.com> Authored: Sat Apr 1 16:44:14 2017 -1000 Committer: wtanaka.com <wtan...@yahoo.com> Committed: Mon Apr 3 18:39:33 2017 -1000 ---------------------------------------------------------------------- .../core/src/main/java/org/apache/beam/sdk/io/CountingInput.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/65b03ebe/sdks/java/core/src/main/java/org/apache/beam/sdk/io/CountingInput.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/CountingInput.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/CountingInput.java index ac70aca..72ebd97 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/CountingInput.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/CountingInput.java @@ -118,6 +118,10 @@ public class CountingInput { /** * A {@link PTransform} that will produce a specified number of {@link Long Longs} starting from * 0. + * + * <pre>{@code + * PCollection<Long> bounded = p.apply(CountingInput.upTo(10L)); + * }</pre> */ public static class BoundedCountingInput extends PTransform<PBegin, PCollection<Long>> { private final long startIndex;
