You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by tg...@apache.org on 2017/03/24 23:46:07 UTC
[3/3] beam git commit: Always require an UnboundedSource to provide a
Checkpoint Coder
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();
/**