Java pass parameters to mapper

public static class MyMapper extends MapReduceBase implements Mapper<...> {

    Integer myIntegerOption;
    String myStringOption;

    @Override
    public void configure(JobConf job) {
        super.configure(job);
        myIntegerOption = job.getInt("myIntOption", -1); 
        // nb: last arg is the default value if option is not set
        myStringOption = job.get("myStringOption", "notSet");
    }

    @Override
    public void map(... key, ... value, 
                    OutputCollector<..> output, Reporter reporter) throws IOException {
        // here you can use the options in your processing
        processRecord(key, value, myIntOption, myStringOption);
    }

}

Source: stackoverflow.com

Similar codes

2 votes111 views1 answer
Java cast duration to long
Java
0 vote100 views1 answer
Java string vers int
Java
0 vote102 views1 answer
Java.applet defines how many interfaces
Java
1 vote114 views2 answers
Lunar New Year
Java
1 vote132 views1 answer
Spring xml file configuration
Java Spring
0 vote107 views1 answer
Java array hashcode
Java
0 vote107 views1 answer
Set union java
Java
6 votes108 views3 answers
How to remove a sting character in java
Java
1 vote132 views1 answer
Java get appdata path
Java
0 vote106 views1 answer
Android java image
Java