| 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> |
no test coverage detected