On the JobConf use the setMapRunnerClass() method to set the
multithreaded
map runner and set the
mapred.map.multithreadedrunner.threads property with
the number of threads you want it to use.
That would do.
And make sure your map() code is thread safe.
A
On Dec 5, 2007 2:44 PM, Peter Thygesen <thygesen infopaq.dk> wrote:
> Can anyone provide me with a java code sample of how I
can use the
> MultithreadedMapRunner
> <http://lucene.apache.org/hadoop/api/org/a
pache/hadoop/mapred/lib/Multit
> hreadedMapRunner.html> ? Or at least some hints?
>
> Please.
>
>
>
> Thx.
>
> Peter
>
>
|