Method ExecAsync

library/cpp/par/par_util.cpp:100–107

            SerializeToMem(&FinalMapSerialized, FinalMap);
        }
        void ExecAsync(IUserContext* ctx, int hostId, TVector<char>* params, IDCResultNotify* dcNotify, int reqId) const override {
            CHROMIUM_TRACE_FUNCTION();
            (void)hostId;
            TJobDescription mapJob;
            SerializeFromMem(params, mapJob);

            ctx->Run(&mapJob, new TExecRemoteReduce(dcNotify, reqId, ctx, Op, FinalMapSerialized));
        }
        void MergeAsync(TVector<TVector<char>>* src, IDCResultNotify* dcNotify, int reqId) const override {
            Y_ASSERT(Op == RR_MAPREDUCE);
            FinalMap->MergeAsync(src, dcNotify, reqId);