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

0 vote232 views1 answer
Grepper editor
Java
0 vote237 views1 answer
Required a bean of type 'org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder' that could not be found.
Java
0 vote217 views1 answer
Java get attributes from class
Java
0 vote234 views1 answer
What is return method in java
Java
0 vote194 views1 answer
Jtable get get row
Java
1 vote231 views1 answer
Get the image from camera click in android
Java
15 votes227 views2 answers
Java time
Java
0 vote212 views1 answer
Random int between two values
Java
0 vote212 views1 answer
Calling activity method from fragment:
Java
1 vote224 views1 answer
How to get array index value into variable in java
Java