Method UpdateDataDistrState

library/cpp/par/par_mr.cpp:62–67

            return AllJobs->HostId2Computer.ysize();
        }
        EDataDistrState UpdateDataDistrState(TVector<TVector<int>>* hostId2Computer) override {
            // this is remote context and it knows nothing about data distribution in progress
            if (hostId2Computer)
                *hostId2Computer = AllJobs->HostId2Computer;
            return DATA_COMPLETE;
        }
        IUserContext* CreateLocalOnlyContext() override;
        TDataLocation RegisterData(int tblId, ui64 versionId, TVector<char>* p) override {
            i64 id = WriteBuffer->SetData(tblId, versionId, p);