Function CalcDistributed

library/cpp/par/par_util.h:213–225

    // TDataCalcer inherits from TMapReduceCmd<TInput,TData>
    template <typename TDataCalcer, typename TData>
    void CalcDistributed(
        int partsCount,
        IEnvironment* env,
        const TDataCalcer& dataCalcer,
        TVector<TData>* data) {
        TJobDescription job;
        job.SetCurrentOperation(dataCalcer);
        for (int part = 0; part < partsCount; ++part) {
            job.AddQuery(part, part);
        }
        TJobExecutor exec(&job, env);
        exec.GetResultVec(data);
    }

    template <typename TDataUpdater>
    void UpdateDistributed(