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
