Implemented map_datum_stream_t::next_batch_impl.
Renamed some variables from "src" to "source".