You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by th...@apache.org on 2016/11/07 19:58:54 UTC
[04/50] incubator-beam git commit: [BEAM-887] Remove false/crashing
"backwards compatibility" from Sink
[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/apex-runner
Commit: 2f6104c903395ac8444fcaab8830e7178ebfe050
Parents: 5224693
Author: Kenneth Knowles <kl...@google.com>
Authored: Wed Nov 2 11:56:43 2016 -0700
Committer: Dan Halperin <dh...@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();
}
/**