fixup! Hide visibility of internal implementation class
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a67ff91e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a67ff91e Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a67ff91e Branch: refs/heads/python-sdk Commit: a67ff91e546cb77ad050e6b7573a884f190840cb Parents: 968c311 Author: Luke Cwik <[email protected]> Authored: Wed Jan 25 14:13:55 2017 -0800 Committer: Luke Cwik <[email protected]> Committed: Wed Jan 25 14:13:55 2017 -0800 ---------------------------------------------------------------------- .../org/apache/beam/sdk/io/BoundedReadFromUnboundedSource.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/a67ff91e/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 f52b822..04e1755 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 @@ -145,7 +145,7 @@ public class BoundedReadFromUnboundedSource<T> extends PTransform<PBegin, PColle * number of records and read time into a {@link BoundedSource}. */ @AutoValue - public abstract static class UnboundedToBoundedSourceAdapter<T> + abstract static class UnboundedToBoundedSourceAdapter<T> extends BoundedSource<ValueWithRecordId<T>> { @Nullable abstract UnboundedSource<T, ?> getSource(); @Nullable abstract long getMaxNumRecords();
