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

3 votes200 views2 answers
Java ArrayList copy
Java
1 vote233 views3 answers
Scroll
Java
0 vote192 views1 answer
How to give intent one project to othrer project activity in anroid
Java
0 vote204 views1 answer
Association in java
Java
2 votes176 views1 answer
Java resize image
Java
0 vote195 views1 answer
Python code to java code converter online
Java
6 votes199 views1 answer
Best IDE for java
Java
0 vote190 views1 answer
Return type of executebatch in java
Java
1 vote174 views1 answer
Space seperator in string in java
Java
0 vote189 views1 answer
Example: My favorite cities
Java