You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jk...@apache.org on 2017/07/22 01:37:12 UTC
[1/2] beam git commit: Unbreaks AvroSource compatibility with
Dataflow worker
Repository: beam
Updated Branches:
refs/heads/master 81c2e90f3 -> f39874860
Unbreaks AvroSource compatibility with Dataflow worker
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4f7d0b4e
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4f7d0b4e
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/4f7d0b4e
Branch: refs/heads/master
Commit: 4f7d0b4ed70b40443aede1ce28d0939f08b1d04f
Parents: 81c2e90
Author: Eugene Kirpichov <ki...@google.com>
Authored: Fri Jul 21 18:01:14 2017 -0700
Committer: Eugene Kirpichov <ki...@google.com>
Committed: Fri Jul 21 18:01:14 2017 -0700
----------------------------------------------------------------------
.../main/java/org/apache/beam/sdk/io/AvroSource.java | 12 ++++++++++++
1 file changed, 12 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/4f7d0b4e/sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroSource.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroSource.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroSource.java
index 30af344..7cd97a8 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroSource.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroSource.java
@@ -201,6 +201,18 @@ public class AvroSource<T> extends BlockBasedSource<T> {
super.validate();
}
+ /**
+ * Used by the Dataflow worker. Do not introduce new usages. Do not delete without confirming that
+ * Dataflow ValidatesRunner tests pass.
+ *
+ * @deprecated Used by Dataflow worker
+ */
+ @Deprecated
+ public BlockBasedSource<T> createForSubrangeOfFile(String fileName, long start, long end)
+ throws IOException {
+ return createForSubrangeOfFile(FileSystems.matchSingleFileSpec(fileName), start, end);
+ }
+
@Override
public BlockBasedSource<T> createForSubrangeOfFile(Metadata fileMetadata, long start, long end) {
return new AvroSource<>(fileMetadata, getMinBundleSize(), start, end, readerSchemaString, type);
[2/2] beam git commit: This closes #3616: Unbreaks AvroSource
compatibility with Dataflow worker
Posted by jk...@apache.org.
This closes #3616: Unbreaks AvroSource compatibility with Dataflow worker
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f3987486
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f3987486
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f3987486
Branch: refs/heads/master
Commit: f39874860027832fdeff957afdc5cc8326de6d30
Parents: 81c2e90 4f7d0b4
Author: Eugene Kirpichov <ki...@google.com>
Authored: Fri Jul 21 18:23:48 2017 -0700
Committer: Eugene Kirpichov <ki...@google.com>
Committed: Fri Jul 21 18:23:48 2017 -0700
----------------------------------------------------------------------
.../main/java/org/apache/beam/sdk/io/AvroSource.java | 12 ++++++++++++
1 file changed, 12 insertions(+)
----------------------------------------------------------------------