You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jb...@apache.org on 2017/04/06 06:08:30 UTC
[1/2] beam git commit: Add javadoc to getEstimatedSizeBytes
Repository: beam
Updated Branches:
refs/heads/master 5fd5828d1 -> 766a02dbc
Add javadoc to getEstimatedSizeBytes
based on code comment in BoundedReadFromUnboundedSource.java
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/56fe0f18
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/56fe0f18
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/56fe0f18
Branch: refs/heads/master
Commit: 56fe0f182d965d3e1d87dfbd8cdeef90b596a905
Parents: 5fd5828
Author: wtanaka.com <wt...@yahoo.com>
Authored: Sun Apr 2 20:02:02 2017 -1000
Committer: Jean-Baptiste Onofr� <jb...@apache.org>
Committed: Thu Apr 6 08:06:45 2017 +0200
----------------------------------------------------------------------
.../core/src/main/java/org/apache/beam/sdk/io/BoundedSource.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/56fe0f18/sdks/java/core/src/main/java/org/apache/beam/sdk/io/BoundedSource.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/BoundedSource.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/BoundedSource.java
index 8538e7f..889f9ab 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/BoundedSource.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/BoundedSource.java
@@ -61,6 +61,9 @@ public abstract class BoundedSource<T> extends Source<T> {
* An estimate of the total size (in bytes) of the data that would be read from this source.
* This estimate is in terms of external storage size, before any decompression or other
* processing done by the reader.
+ *
+ * If there is no way to estimate the size of the source
+ * implementations MAY return 0L
*/
public abstract long getEstimatedSizeBytes(PipelineOptions options) throws Exception;
[2/2] beam git commit: This closes #2405
Posted by jb...@apache.org.
This closes #2405
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/766a02db
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/766a02db
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/766a02db
Branch: refs/heads/master
Commit: 766a02dbc6b3f0b89290d831771041b2b40ef3cc
Parents: 5fd5828 56fe0f1
Author: Jean-Baptiste Onofr� <jb...@apache.org>
Authored: Thu Apr 6 08:08:21 2017 +0200
Committer: Jean-Baptiste Onofr� <jb...@apache.org>
Committed: Thu Apr 6 08:08:21 2017 +0200
----------------------------------------------------------------------
.../core/src/main/java/org/apache/beam/sdk/io/BoundedSource.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------