You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jb...@apache.org on 2017/04/17 09:03:56 UTC
[1/2] beam git commit: Add javadoc to getCheckpointMark in
UnboundedSource
Repository: beam
Updated Branches:
refs/heads/master f7d727c0f -> 9b8f23095
Add javadoc to getCheckpointMark in UnboundedSource
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c62d698f
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c62d698f
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c62d698f
Branch: refs/heads/master
Commit: c62d698f52cab716f226ca4aec40718bf851a14c
Parents: f7d727c
Author: wtanaka.com <wt...@yahoo.com>
Authored: Sun Apr 2 23:02:00 2017 -1000
Committer: Jean-Baptiste Onofr� <jb...@apache.org>
Committed: Mon Apr 17 09:49:49 2017 +0200
----------------------------------------------------------------------
.../java/org/apache/beam/sdk/io/UnboundedSource.java | 13 +++++++++++++
1 file changed, 13 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/c62d698f/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 3f1ba0e..cc1f598 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
@@ -220,6 +220,19 @@ public abstract class UnboundedSource<
/**
* Returns a {@link CheckpointMark} representing the progress of this {@code UnboundedReader}.
*
+ * <p>If this {@code UnboundedReader} does not support checkpoints, it may return a
+ * CheckpointMark which does nothing, like:
+ *
+ * <pre>{@code
+ * public UnboundedSource.CheckpointMark getCheckpointMark() {
+ * return new UnboundedSource.CheckpointMark() {
+ * public void finalizeCheckpoint() throws IOException {
+ * // nothing to do
+ * }
+ * };
+ * }
+ * }</pre>
+ *
* <p>All elements read up until this method is called will be processed together as a bundle.
* (An element is considered 'read' if it could be returned by a call to {@link #getCurrent}.)
* Once the result of processing those elements and the returned checkpoint have been durably
[2/2] beam git commit: This closes #2406
Posted by jb...@apache.org.
This closes #2406
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9b8f2309
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9b8f2309
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9b8f2309
Branch: refs/heads/master
Commit: 9b8f23095665cc7d7872969290a01847de8071b6
Parents: f7d727c c62d698
Author: Jean-Baptiste Onofr� <jb...@apache.org>
Authored: Mon Apr 17 11:03:51 2017 +0200
Committer: Jean-Baptiste Onofr� <jb...@apache.org>
Committed: Mon Apr 17 11:03:51 2017 +0200
----------------------------------------------------------------------
.../java/org/apache/beam/sdk/io/UnboundedSource.java | 13 +++++++++++++
1 file changed, 13 insertions(+)
----------------------------------------------------------------------