You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2017/04/21 01:29:32 UTC
[1/2] beam git commit: [BEAM-2012] Remove
BoundedSource.splitIntoBundles for real
Repository: beam
Updated Branches:
refs/heads/master e4eae7bce -> 28665490f
[BEAM-2012] Remove BoundedSource.splitIntoBundles for real
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/abe9e948
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/abe9e948
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/abe9e948
Branch: refs/heads/master
Commit: abe9e948eb8cc4c5ca6ce00c51e5fd9d412899b9
Parents: e4eae7b
Author: Dan Halperin <dh...@google.com>
Authored: Thu Apr 20 17:27:12 2017 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Thu Apr 20 18:29:20 2017 -0700
----------------------------------------------------------------------
runners/google-cloud-dataflow-java/pom.xml | 2 +-
.../src/main/java/org/apache/beam/sdk/io/BoundedSource.java | 9 ---------
2 files changed, 1 insertion(+), 10 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/abe9e948/runners/google-cloud-dataflow-java/pom.xml
----------------------------------------------------------------------
diff --git a/runners/google-cloud-dataflow-java/pom.xml b/runners/google-cloud-dataflow-java/pom.xml
index 4cde923..3051ada 100644
--- a/runners/google-cloud-dataflow-java/pom.xml
+++ b/runners/google-cloud-dataflow-java/pom.xml
@@ -33,7 +33,7 @@
<packaging>jar</packaging>
<properties>
- <dataflow.container_version>beam-master-20170418</dataflow.container_version>
+ <dataflow.container_version>beam-master-20170420</dataflow.container_version>
<dataflow.fnapi_environment_major_version>1</dataflow.fnapi_environment_major_version>
<dataflow.legacy_environment_major_version>6</dataflow.legacy_environment_major_version>
</properties>
http://git-wip-us.apache.org/repos/asf/beam/blob/abe9e948/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 0b19aa2..9788b82 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
@@ -58,15 +58,6 @@ public abstract class BoundedSource<T> extends Source<T> {
long desiredBundleSizeBytes, PipelineOptions options) throws Exception;
/**
- * {@link BoundedSource#split(long, PipelineOptions)} old method name to be used with Dataflow.
- */
- @Deprecated
- public List<? extends BoundedSource<T>> splitIntoBundles(
- long desiredBundleSizeBytes, PipelineOptions options) throws Exception{
- return split(desiredBundleSizeBytes, options);
- }
-
- /**
* 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.
[2/2] beam git commit: This closes #2621
Posted by dh...@apache.org.
This closes #2621
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/28665490
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/28665490
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/28665490
Branch: refs/heads/master
Commit: 28665490f6ad0cad091f4f936a8f113617fd3f27
Parents: e4eae7b abe9e94
Author: Dan Halperin <dh...@google.com>
Authored: Thu Apr 20 18:29:22 2017 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Thu Apr 20 18:29:22 2017 -0700
----------------------------------------------------------------------
runners/google-cloud-dataflow-java/pom.xml | 2 +-
.../src/main/java/org/apache/beam/sdk/io/BoundedSource.java | 9 ---------
2 files changed, 1 insertion(+), 10 deletions(-)
----------------------------------------------------------------------