Function CollectData

library/cpp/par/par_wb.cpp:77–90

    };

    void CollectData(const TVector<TDataLocation>& data, TVector<TVector<char>>* res,
                     TLocalDataBuffer* writeBuffer, TRemoteQueryProcessor* queryProc) {
        CHROMIUM_TRACE_FUNCTION();

        THashMap<int, TWBCopyCompInfo> comp2req;
        for (int i = 0; i < data.ysize(); ++i) {
            const TDataLocation& dl = data[i];
            TWBCopyCompInfo& info = comp2req[dl.CompId];
            info.OriginalPlace.push_back(i);
            info.Data.push_back(dl.DataId);
        }
        TIntrusivePtr<TDataCollector> dc = new TDataCollector(&comp2req);
        dc->Run(writeBuffer, queryProc, res);
    }
}