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

14 votes149 views2 answers
What method is use for getting the index position of a character of a string in java
Java
0 vote137 views1 answer
How to get orientation lock to portrait android stackoverflow
Java
1 vote143 views3 answers
How to sort array java
Java
0 vote133 views1 answer
How to extend a class in java
Java
4 votes167 views2 answers
Generate 5 digit random string in java
Java
0 vote164 views2 answers
Close GUI in jvava
Java
0 vote129 views1 answer
Kotlin registerForActivityResult
Java
29 votes123 views3 answers
Array of char to string in java
Java
0 vote142 views1 answer
How to accept only numbers and whitespace in java
Java
0 vote153 views1 answer
How to send images to storage using Admin Sdk in java
Java