Polymorphic mapper and reducer for concurrent pi