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

1 vote220 views3 answers
Convert base64 to bitmap android
Java
0 vote195 views1 answer
Are inner classes inherited
Java
0 vote206 views1 answer
Java check if sql table exists
Java
0 vote206 views1 answer
Getresources in adapter android
Java
0 vote196 views1 answer
Java calendar add minutes
Java
4 votes226 views3 answers
Android dialog modal
Java
0 vote209 views1 answer
Treeset java descending order using comparator
Java
0 vote191 views1 answer
How to show the hex detail of a file in java
Java
0 vote197 views1 answer
Intent pick action video android
Java
4 votes172 views3 answers
Cast long to string java
Java