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 <[email protected]> Authored: Thu Apr 20 17:27:12 2017 -0700 Committer: Dan Halperin <[email protected]> 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.
