Clarification: likely you meant TestStream <https://github.com/apache/beam/blob/master/sdks/java/core/src/main/java/org/apache/beam/sdk/testing/TestStream.java> ?
On Sat, Apr 29, 2017 at 10:03 PM Jean-Baptiste Onofré <[email protected]> wrote: > Hi, > > In addition of Eugene and Jesse's answers, for testing purpose, it's > possible to > use CreateStream in some runners. It allows us to test streaming. > > Regards > JB > > On 04/29/2017 09:50 PM, Shen Li wrote: > > It seems that Create.of(Iterable) can only create a BoundedSource. Is > there > > a convenient way to read from an unbounded Iterable object without > writing > > application code to wrap it into an UnboundedSource object? > > > > > > Thanks, > > > > Shen > > > > -- > Jean-Baptiste Onofré > [email protected] > http://blog.nanthrax.net > Talend - http://www.talend.com >
