beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [1/2] incubator-beam git commit: [BEAM-887] Remove false/crashing "backwards compatibility" from Sink
Date Wed, 02 Nov 2016 22:53:38 GMT
Repository: incubator-beam
Updated Branches:
  refs/heads/master 522469330 -> 4dec38cee


[BEAM-887] Remove false/crashing "backwards compatibility" from Sink


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

Branch: refs/heads/master
Commit: 2f6104c903395ac8444fcaab8830e7178ebfe050
Parents: 5224693
Author: Kenneth Knowles <klk@google.com>
Authored: Wed Nov 2 11:56:43 2016 -0700
Committer: Dan Halperin <dhalperi@google.com>
Committed: Wed Nov 2 15:53:19 2016 -0700

----------------------------------------------------------------------
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/Sink.java | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/2f6104c9/sdks/java/core/src/main/java/org/apache/beam/sdk/io/Sink.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/Sink.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/Sink.java
index f256c5f..d1770c8 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/Sink.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/Sink.java
@@ -214,9 +214,7 @@ public abstract class Sink<T> implements Serializable, HasDisplayData
{
     /**
      * Returns a coder for the writer result type.
      */
-    public Coder<WriteT> getWriterResultCoder() {
-      return null;
-    }
+    public abstract Coder<WriteT> getWriterResultCoder();
   }
 
   /**


Mime
View raw message