Hello I am working on RichProcessFunction and I want to emit multiple records at a time. To achieve this, I am currently doing :
while(condition) { Collector.collect(new Tuple<>...); } I was wondering, is this the correct way or there is any other alternative.