Does Spark streaming support iterative operator?

2015-12-03 Thread Wang Yangjun
Hi, In storm we could do thing like: TopologyBuilder builder = new TopologyBuilder(); builder.setSpout("spout", new NumberSpout()); builder.setBolt(“mybolt", new Mybolt()) .shuffleGrouping("spout") .shuffleGrouping(“mybolt", “iterativeStream"); It means that after one operation

Re: Does Spark streaming support iterative operator?

2015-12-03 Thread Wang Yangjun
e batch's RDD that you like. > >On Thu, Dec 3, 2015 at 8:04 PM, Wang Yangjun <yangjun.w...@aalto.fi> wrote: >> Hi, >> >> In storm we could do thing like: >> >> TopologyBuilder builder = new TopologyBuilder(); >> >> builder.s