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/master Commit: 968c31122395d120117ed725aad83d5e3a47e3b1 Parents: eeec9f1 Author: Kai Jiang <jiang...@gmail.com> Authored: Wed Jan 25 04:49:35 2017 -0800 Committer: Kai Jiang <jiang...@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
