Hello,

I am trying to setup my Mapper class before it is set-up to run as a
task.  Specifically, I am trying to override the method
Mapper.setup(Mapper.Context).  When I run the MapReduce program I am
expecting an output to stdout of about about 6 lines along with the
configuration information read out of the Context.  I have two
questions:

--- Am I correctly setting up the mapper set task?
--- Do I need to print/debug messages through an API of some sort, or
is printing output to stdout OK?

I am using the 0.21 Hadoop API with a Single Host set-up.  Below is a
sample of how I am using the set-up method.  Any help is greatly
appreciated.



        public static class MyMapperClass extends
                        Reducer<Object, Text, Text, Text> {

                
                private Integer daysWindow;
                private static final HashMap<Long, HashSet<Long>>
windowedIpAddresses = new HashMap<Long, HashSet<Long>>();
                
                
                private Long minTimestamp, maxTimestamp;
                private Configuration configuration;
                public void setup(Context context)
                throws IOException, InterruptedException{
                        
                        Configuration conf = context.getConfiguration();
                        System.out.println("Map.configure();");
                        this.configuration = conf;

                        this.minTimestamp = this.configuration.getLong(
                                        MIN_TIMESTAMP_WINDOW, 0);
                        this.maxTimestamp = this.configuration.getLong(
                                        MAX_TIMESTAMP_WINDOW, 0);
                        this.daysWindow = 
this.configuration.getInt(DAYS_WINDOW, 0);
                        System.out.println("\n\n\n\n\n\n\nminTimestamp :=
"+Long.toString(minTimestamp)+" maxTimestamp :=
"+Long.toString(maxTimestamp));

                }
public void map(Object key, Text value, Context context)
                                throws IOException, InterruptedException {}
}

Reply via email to