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
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