flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vasiliki Kalavri <vasilikikala...@gmail.com>
Subject Re: flink loop
Date Thu, 05 Feb 2015 19:51:08 GMT
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 <tanracinet@gmail.com> 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 : tanracinet@gmail.com
>
> ᐧ
>

Mime
View raw message