Repository: beam Updated Branches: refs/heads/master a8edbb81f -> e0df45850
BEAM-1851: Update documentation for for fixedSizeGlobally to be clear about memory constraints. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5b1d73fe Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5b1d73fe Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/5b1d73fe Branch: refs/heads/master Commit: 5b1d73fee3994784fd826aea1a7fc81c261d093f Parents: a8edbb8 Author: mdshalda <[email protected]> Authored: Wed Apr 5 22:23:00 2017 -0700 Committer: Davor Bonaci <[email protected]> Committed: Fri Apr 7 17:12:06 2017 +0200 ---------------------------------------------------------------------- .../src/main/java/org/apache/beam/sdk/transforms/Sample.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/5b1d73fe/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Sample.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Sample.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Sample.java index 3d35c80..f3bd07a 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Sample.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Sample.java @@ -81,6 +81,10 @@ public class Sample { * selected elements. If the input {@code PCollection} has fewer than {@code sampleSize} elements, * then the output {@code Iterable<T>} will be all the input's elements. * + * <p>All of the elements of the output {@code PCollection} should fit into + * main memory of a single worker machine. This operation does not + * run in parallel. + * * <p>Example of use: * * <pre>{@code
