beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [1/2] beam git commit: Unbreaks AvroSource compatibility with Dataflow worker
Date Sat, 22 Jul 2017 01:37:12 GMT
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 <kirpichov@google.com>
Authored: Fri Jul 21 18:01:14 2017 -0700
Committer: Eugene Kirpichov <kirpichov@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);


Mime
View raw message