Method MRCommandComplete

library/cpp/par/par_exec.h:629–642

            TVector<int> ResultMap;

            void MRCommandComplete(bool isCanceled, TVector<TVector<char>>* res) override {
                if (isCanceled)
                    Parent->Cancel();
                else {
                    // copy results
                    Y_ASSERT(ResultMap.ysize() == res->ysize());
                    int count = ResultMap.ysize();
                    for (int i = 0; i < count; ++i)
                        Parent->ResultData[ResultMap[i]].swap((*res)[i]);
                    AtomicAdd(Parent->ActiveOpCount, -1);

                    Parent->StartNextBlock();
                }
            }
            TGUID GetMasterQueryId() override {
                return Parent->MasterGuid;
            }