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 vote355 views1 answer
Java get temp dir
Java
0 vote368 views1 answer
Plus One LeetCode Java
Java
0 vote363 views2 answers
@embeddedid
Java
0 vote336 views1 answer
Set view layout params android
Java
0 vote344 views1 answer
Add element in the last in double linked list in java
Java
4 votes352 views4 answers
Main method in java
Java
0 vote298 views1 answer
What is final class
Java
1 vote343 views1 answer
How to implement linked list in java without using collection framework
Java
0 vote383 views1 answer
The crystallization in time is the phenomenon that we call synchronization
Java
5 votes405 views2 answers
This project uses AndroidX dependencies, but the 'android.useAndroidX' property is not enabled
Java