You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by da...@apache.org on 2017/04/07 15:12:31 UTC
[1/2] beam git commit: BEAM-1851: Update documentation for for
fixedSizeGlobally to be clear about memory constraints.
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 <md...@gmail.com>
Authored: Wed Apr 5 22:23:00 2017 -0700
Committer: Davor Bonaci <da...@google.com>
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
[2/2] beam git commit: This closes #2451
Posted by da...@apache.org.
This closes #2451
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e0df4585
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e0df4585
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e0df4585
Branch: refs/heads/master
Commit: e0df45850f8e7dc3d905afbca011c492a68b492f
Parents: a8edbb8 5b1d73f
Author: Davor Bonaci <da...@google.com>
Authored: Fri Apr 7 17:12:15 2017 +0200
Committer: Davor Bonaci <da...@google.com>
Committed: Fri Apr 7 17:12:15 2017 +0200
----------------------------------------------------------------------
.../src/main/java/org/apache/beam/sdk/transforms/Sample.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------