Method MRCommandComplete

library/cpp/par/par_util.cpp:31–59

        ECurrentCommand State;

        void MRCommandComplete(bool isCanceled, TVector<TVector<char>>* res) override {
            CHROMIUM_TRACE_FUNCTION();
            if (isCanceled) {
                DCNotify->DistrCmdComplete(ReqId, nullptr);
                return;
            }
            if (State == FIRST_MAP) {
                TJobDescription fmJob;
                fmJob.SetCurrentOperation(FinalMapSerialized);
                for (int i = 0; i < res->ysize(); ++i)
                    fmJob.AddQuery(-1, &(*res)[i]);
                if (Op == RR_MAPREDUCE)
                    fmJob.MergeResults();

                State = REMOTE_MAP;
                Ctx->Run(&fmJob, this);

            } else if (State == REMOTE_MAP) {
                TVector<char> dcRes;
                if (Op == RR_MAP) {
                    SerializeToMem(&dcRes, *res);
                } else {
                    Y_ASSERT(res->ysize() == 1);
                    dcRes.swap((*res)[0]);
                }
                DCNotify->DistrCmdComplete(ReqId, &dcRes);
            } else
                Y_ASSERT(0);
        }
        TGUID GetMasterQueryId() override {
            return DCNotify->GetDistrCmdMasterQueryId();
        }