beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From reuven...@apache.org
Subject [1/2] beam git commit: Fix type parameter in AvroIO.Write
Date Fri, 22 Sep 2017 19:18:35 GMT
Repository: beam
Updated Branches:
  refs/heads/master 66b864f2b -> 87116cc74


Fix type parameter in AvroIO.Write

Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3bd7ddbf
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3bd7ddbf
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3bd7ddbf

Branch: refs/heads/master
Commit: 3bd7ddbf7a836091092e8116e6637b97e306cbc4
Parents: 66b864f
Author: Neville Li <neville.lyh@gmail.com>
Authored: Wed Aug 9 17:35:21 2017 -0400
Committer: Reuven Lax <relax@relax-macbookpro2.roam.corp.google.com>
Committed: Fri Sep 22 12:03:36 2017 -0700

----------------------------------------------------------------------
 .../core/src/main/java/org/apache/beam/sdk/io/AvroIO.java | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/beam/blob/3bd7ddbf/sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroIO.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroIO.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroIO.java
index 108054f..e05ffb5 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroIO.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroIO.java
@@ -1238,12 +1238,12 @@ public class AvroIO {
     }
 
     /** See {@link TypedWrite#to(DynamicAvroDestinations)}. */
-    public Write to(DynamicAvroDestinations<T, ?, T> dynamicDestinations) {
+    public Write<T> to(DynamicAvroDestinations<T, ?, T> dynamicDestinations)
{
       return new Write<>(inner.to(dynamicDestinations).withFormatFunction(null));
     }
 
     /** See {@link TypedWrite#withSchema}. */
-    public Write withSchema(Schema schema) {
+    public Write<T> withSchema(Schema schema) {
       return new Write<>(inner.withSchema(schema));
     }
     /** See {@link TypedWrite#withTempDirectory(ValueProvider)}. */
@@ -1278,8 +1278,8 @@ public class AvroIO {
     }
 
     /** See {@link TypedWrite#withWindowedWrites}. */
-    public Write withWindowedWrites() {
-      return new Write<T>(inner.withWindowedWrites());
+    public Write<T> withWindowedWrites() {
+      return new Write<>(inner.withWindowedWrites());
     }
 
     /** See {@link TypedWrite#withCodec}. */
@@ -1302,7 +1302,7 @@ public class AvroIO {
     }
 
     /** See {@link TypedWrite#withMetadata} . */
-    public Write withMetadata(Map<String, Object> metadata) {
+    public Write<T> withMetadata(Map<String, Object> metadata) {
       return new Write<>(inner.withMetadata(metadata));
     }
 


Mime
View raw message