Hi, I'm not familiar with the particular algorithm, but you can most probably use one of the two iterate operators in Flink.
You can read a description and see some examples in the documentation: http://flink.apache.org/docs/0.8/programming_guide.html#iteration-operators Let us know if you have any questions! Cheers, V. On 5 February 2015 at 20:37, tanguy racinet <[email protected]> wrote: > Hi, > > We are trying to develop the Apriori algorith with the Flink for our Data > minning project. > In our understanding, Flink could handle loop within the workflow. > However, our knowledge is limited and we cannot find a nice way to do it. > > Here is the flow of my algorithm : > GenerateCandidates ----> CalculateFrequentItemSet > mapper ----> reducer > > We would like to use the reducer result as the mapper's entry for a > predefined number of times (loop x times). > > Is there any smart way to that with Flink. Or should we just copy paste > the loop x times ? > > Thank you, > <http://eitictlabs-rennes.fr/> > > > *Racinet Tanguy* > > *EIT ICT Labs Master School Student* > *Distributed Systems and Services* > > Tel : +33 6 63 20 89 16 / +49 176 3749 8854 > Mail : [email protected] > > ᐧ >
