Thanks JB.I am executing FlinkPipelineRunner...& later will experirnt the same
with SparkRunner....any examples pls?Cheers
From: Jean-Baptiste Onofré <[email protected]>
To: [email protected]
Sent: Monday, June 20, 2016 12:35 PM
Subject: Re: Multi-threading implementation equivalence in Beam
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
