beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [1/2] incubator-beam git commit: BoundedReadFromUnboundedSource: make public
Date Thu, 20 Oct 2016 17:17:22 GMT
Repository: incubator-beam
Updated Branches:
  refs/heads/master b5e15c23a -> ff6301bd6


BoundedReadFromUnboundedSource: make public

Useful outside of the sdk.io module


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/79b1ddd7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/79b1ddd7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/79b1ddd7

Branch: refs/heads/master
Commit: 79b1ddd7f41b7ac577b40092e83ef526b5201b7c
Parents: b5e15c2
Author: Dan Halperin <dhalperi@google.com>
Authored: Thu Oct 20 09:16:09 2016 -0700
Committer: Dan Halperin <dhalperi@google.com>
Committed: Thu Oct 20 10:17:15 2016 -0700

----------------------------------------------------------------------
 .../org/apache/beam/sdk/io/BoundedReadFromUnboundedSource.java   | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/79b1ddd7/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 301a45e..630a8a3 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
@@ -45,10 +45,8 @@ import org.joda.time.Instant;
 /**
  * {@link PTransform} that reads a bounded amount of data from an {@link UnboundedSource},
  * specified as one or both of a maximum number of elements or a maximum period of time to
read.
- *
- * <p>Created by {@link Read}.
  */
-class BoundedReadFromUnboundedSource<T> extends PTransform<PBegin, PCollection<T>>
{
+public class BoundedReadFromUnboundedSource<T> extends PTransform<PBegin, PCollection<T>>
{
   private final UnboundedSource<T, ?> source;
   private final long maxNumRecords;
   private final Duration maxReadTime;


Mime
View raw message