mongodb map-reduce for flumapper data pipeline