Function Map

library/cpp/par/par_util.h:100–105

    template <class TInput, class TOutput>
    inline void Map(TJobDescription* job, TMapReduceCmd<TInput, TOutput>* cmd, TVector<TInput>* src) {
        job->SetCurrentOperation(cmd);
        TVector<char> buf;
        for (int i = 0; i < src->ysize(); ++i)
            job->AddMap((*src)[i]);
    }

    class TJobExecutor {
        class TCallback: public IMRCommandCompleteNotify {