Always require an UnboundedSource to provide a Checkpoint Coder The coder can do no work, but should always be specified.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4c1f2e4f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4c1f2e4f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/4c1f2e4f Branch: refs/heads/master Commit: 4c1f2e4f496a9695517f6a3fbc953e910fb991ac Parents: d63235c Author: Thomas Groh <tg...@google.com> Authored: Fri Mar 24 14:36:12 2017 -0700 Committer: Thomas Groh <tg...@google.com> Committed: Fri Mar 24 16:45:55 2017 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/beam/sdk/io/UnboundedSource.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/4c1f2e4f/sdks/java/core/src/main/java/org/apache/beam/sdk/io/UnboundedSource.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/UnboundedSource.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/UnboundedSource.java index 043f2fc..3f1ba0e 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/UnboundedSource.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/UnboundedSource.java @@ -76,10 +76,8 @@ public abstract class UnboundedSource< PipelineOptions options, @Nullable CheckpointMarkT checkpointMark) throws IOException; /** - * Returns a {@link Coder} for encoding and decoding the checkpoints for this source, or - * null if the checkpoints do not need to be durably committed. + * Returns a {@link Coder} for encoding and decoding the checkpoints for this source. */ - @Nullable public abstract Coder<CheckpointMarkT> getCheckpointMarkCoder(); /**