K1
- V1
- K2
- V2
- public class MultithreadedSharingMapper<K1,V1,K2,V2>
extends org.apache.hadoop.mapreduce.lib.map.MultithreadedMapper<K1,V1,K2,V2>
SharingMapper
s. Will call setupSharedInstance() once in the controlling thread
before executing the mappers using a thread pool.Constructor and Description |
---|
MultithreadedSharingMapper() |
Modifier and Type | Method and Description |
---|---|
void |
run(org.apache.hadoop.mapreduce.Mapper.Context ctx) |
public void run(org.apache.hadoop.mapreduce.Mapper.Context ctx) throws IOException, InterruptedException
run
in class org.apache.hadoop.mapreduce.lib.map.MultithreadedMapper<K1,V1,K2,V2>
IOException
InterruptedException
Copyright © 2008–2015 The Apache Software Foundation. All rights reserved.