Hello Sir, Please find the explanation below:
Aalekh, > > > After carefully re-evaluation of API specifications of hpxflow (HPX batch > > and stream processing framework), I now would like to invite all the > > community members to please share their review regarding the > specification > > here: > > > https://docs.google.com/document/d/1jBuKDjAbt_nET_wBAUjFl7PFoLdbLz5CZbB9r1 > > sqlGM/edit?usp=sharing > > Thanks for this design write-up! That's very useful. I have a couple of > questions, though: > > You have this example: > > hpx::parallel::for_each( > hpx::parallel::par, > std::begin(moneyValues), std::end(moneyValues), > [](std::size_t val) > { > hpx::flow::return_result( > hpx::flow::trigger(currencyConversion(val))); > }); > > Could you elaborate, what are the trigger() and return_result() functions > are for, please? > trigger function: trigger function basically emulates the property of trigger in DataFlow pipeline model (here: https://cloud.google.com/dataflow/model/triggers), used to execute some user defined function(in this case: currencyConversion). return_result: It returns results from trigger function, in future implementation I plan (in second iteration of project) to make this function for storing processed data (from hpx::flow::trigger) to Hypertables > > In the next example: > > auto a(input.add( "input_a", line2 )); > auto b(input.add( "input_b", line3 )); > auto c(output.add( "sum" )); > > // fn1 is function_to_be_applied_between_the_two variables > c = operation(*a, *b, fn1); > > Could you please elaborate what this code is doing? Why do you use pointer > dereferencing for 'a' and 'b'? What does that mean? > Also, line2 and line3 are simply concatenated strings (separated by \n, I > presume), is the operation() taking those apart? > What will 'c' contain after the execution of this code? > > Auto a, b and c variables are used to assign input specifier to data source, here line2 and line 3 are two input sources for stream sources, and "auto c" is a pipeline for output from processing "auto a" and "auto b" data sources(in this example: summation), further operation is used to operate function(in this example : fn1) over two pipelines data sources (in this example: a and b). Thanks, Aalekh > > > > Thanks, > > Aalekh > > > > On Wed, May 18, 2016 at 3:52 PM, Patrick Diehl <[email protected]> > > wrote: > > Hi, > > > > I just look with him at the document and he will provide addtional > > information and extend it. Then I will write a second mail when we can > > discuss it. > > > > Best, > > > > Patrick > > > > Am 05/18/2016 um 11:55 AM schrieb Aalekh Nigam: > > > Hello Everyone, > > > > > > Through this mail I would like to invite all the community members to > > > review some of the Stream and Batch Processing Framework API > > > specifications to be developed over HPX as a part of my GSOC project. > > > Link to API specification: > > > > > > > > > https://docs.google.com/document/d/1jBuKDjAbt_nET_wBAUjFl7PFoLdbLz5CZbB9r1 > > sqlGM/edit?usp=sharing > > > > > > Thanks, > > > Aalekh > > > > > > > > > > > > _______________________________________________ > > > hpx-users mailing list > > > [email protected] > > > https://mail.cct.lsu.edu/mailman/listinfo/hpx-users > > > > > > > -- > > Patrick Diehl > > Institut für Numerische Simulation > > Rheinische Friedrich-Wilhelms Universität Bonn > > Wegelerstrasse 4 , Room 0.001 > > D-53115 Bonn Germany > > Tel : +49 228 733846 > > Mail: [email protected] > > > > > > _______________________________________________ > > hpx-users mailing list > > [email protected] > > https://mail.cct.lsu.edu/mailman/listinfo/hpx-users > > >
_______________________________________________ hpx-users mailing list [email protected] https://mail.cct.lsu.edu/mailman/listinfo/hpx-users
