Hi Shen, Most runners are expected to use `UnboundedReadFromBoundedSource` (in `runners-core-construction`) to convert a BoundedSource to an UnboundedSource if that is the semantics they need.
As Eugene says, I suspect you can also get similar behavior with a SplittableDoFn. Dan On Sat, Apr 29, 2017 at 10:56 PM, Jean-Baptiste Onofré <[email protected]> wrote: > Yes, sorry, TestStream (a bit early in the morning ;)). > > Thanks to have corrected me ;) > > Regards > JB > > > On 04/30/2017 07:17 AM, Eugene Kirpichov wrote: > >> 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 >>> >>> >> > -- > Jean-Baptiste Onofré > [email protected] > http://blog.nanthrax.net > Talend - http://www.talend.com >
