Hi, My mapper calls remote client to retrieve certain result. I plan to introduce asynchronous client calls and buffer results in mapper before calling output.collect().
Is there a way to detect whether the current call to MapClass.map() is the last one ? Thanks
