You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2017/01/29 16:22:02 UTC
[16/50] beam git commit: address comments
address comments
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/968c3112
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/968c3112
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/968c3112
Branch: refs/heads/python-sdk
Commit: 968c31122395d120117ed725aad83d5e3a47e3b1
Parents: eeec9f1
Author: Kai Jiang <ji...@gmail.com>
Authored: Wed Jan 25 04:49:35 2017 -0800
Committer: Kai Jiang <ji...@gmail.com>
Committed: Wed Jan 25 05:09:33 2017 -0800
----------------------------------------------------------------------
.../org/apache/beam/sdk/io/BoundedReadFromUnboundedSource.java | 6 ++----
1 file changed, 2 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/968c3112/sdks/java/core/src/main/java/org/apache/beam/sdk/io/BoundedReadFromUnboundedSource.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/BoundedReadFromUnboundedSource.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/BoundedReadFromUnboundedSource.java
index 7e25a01..f52b822 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/BoundedReadFromUnboundedSource.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/BoundedReadFromUnboundedSource.java
@@ -141,8 +141,8 @@ public class BoundedReadFromUnboundedSource<T> extends PTransform<PBegin, PColle
}
/**
- * An Adapter wraps the underlying {@link UnboundedSource} with the specified bounds on
- * number of records and read time into {@link BoundedSource}.
+ * Adapter that wraps the underlying {@link UnboundedSource} with the specified bounds on
+ * number of records and read time into a {@link BoundedSource}.
*/
@AutoValue
public abstract static class UnboundedToBoundedSourceAdapter<T>
@@ -151,8 +151,6 @@ public class BoundedReadFromUnboundedSource<T> extends PTransform<PBegin, PColle
@Nullable abstract long getMaxNumRecords();
@Nullable abstract Duration getMaxReadTime();
- public abstract String toString();
-
abstract Builder<T> toBuilder();
@AutoValue.Builder