MCPcopy Create free account
hub / github.com/catboost/catboost / RunMapReduce

Function RunMapReduce

library/cpp/par/par_util.h:194–200  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

192
193 template <class TInput, class TOutput>
194 inline void RunMapReduce(IEnvironment* env, TMapReduceCmd<TInput, TOutput>* cmd, TVector<TInput>* src, TOutput* dst) {
195 TJobDescription jop;
196 Map(&jop, cmd, src);
197 jop.MergeResults();
198 TJobExecutor exec(&jop, env);
199 exec.GetResult(dst);
200 }
201
202 void MakeRunOnRangeImpl(TJobDescription* job, int start, int finish, IDistrCmd* finalMap);
203 template <class TOutput>

Callers 1

UpdateLeavesExactFunction · 0.85

Calls 3

MergeResultsMethod · 0.80
MapFunction · 0.70
GetResultMethod · 0.45

Tested by

no test coverage detected