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 <k...@google.com> Authored: Wed Nov 2 11:56:43 2016 -0700 Committer: Dan Halperin <dhalp...@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(); } /**
