Hi
I have written a mapper class that has the following structure
public class TestMapper extends MapReduceBase implements
Mapper<LongWritable, Text, Text, Text> {
public void configure(JobConf conf) {
Path [] cacheFiles = DistributedCache.getLocalCacheFiles(conf);
if (null != cacheFiles && cacheFiles.length > 0) {
for (Path cachePath : cacheFiles) {
if (cachePath.getName().equals(stopwordCacheName)) {
loadStopWords(cachePath);
break;
}
if (cachePath.getName().equals(positiveCacheName)) {
loadPositiveWords(cachePath);
break;
}
if (cachePath.getName().equals(negativeCacheName)) {
loadNegativeWords(cachePath);
break;
}
if (cachePath.getName().equals(searchCacheName)) {
loadSearchWords(cachePath);
break;
}
}
//Mapper logic goes here
}
Config method should get called before the mapper method by default
right?
But that's not happening..... and the loggers I have used inside mapper
are not getting printed on console and there are no loga in userlogs.
Userlogs is empty. Logger
statements(sLogger.debug("*****************uploaded positive words");)
in the driver class are getting printed on the console though.
Regards,
Shreya
This e-mail and any files transmitted with it are for the sole use of the
intended recipient(s) and may contain confidential and privileged information.
If you are not the intended recipient(s), please reply to the sender and
destroy all copies of the original message. Any unauthorized review, use,
disclosure, dissemination, forwarding, printing or copying of this email,
and/or any action taken in reliance on the contents of this e-mail is strictly
prohibited and may be unlawful.
