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

10 votes213 views3 answers
Java check if int
Java
0 vote229 views2 answers
How do I change the opacity of a JButton
Java
0 vote197 views1 answer
Java to python
Java
2 votes173 views1 answer
Error: java_home is not set and could not be found.
Java
3 votes191 views1 answer
Padding a string with 0 in java
Java
0 vote193 views1 answer
Split() String android
Java
3 votes185 views1 answer
New in japanese
Java
0 vote181 views1 answer
How does java knows where it has stored primitive data type
Java
4 votes206 views4 answers
Java while loop example
Java
5 votes188 views3 answers
How to install java 8 on ubuntu 20.04
Java