Hi Amir,
the DirectPipelineRunner uses multi-thread to achieve ParDo execution
for instance.
You mean example of Beam pipeline code ? Or example of runner ?
Regards
JB
On 06/20/2016 09:25 PM, amir bahmanyari wrote:
Hi Colleagues,
Hope you all had a great weekend. Another novice question :-)
Is there a pipeline parallelism/threading model provide by Beam that
equates the multi-threading model in Java for instance?
Any examples if so?
Thanks again,
Amir
--
Jean-Baptiste Onofré
[email protected]
http://blog.nanthrax.net
Talend - http://www.talend.com
