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 vote127 views1 answer
Computeifabsent hashmap java
Java
4 votes110 views3 answers
Java loop object
Java
0 vote117 views1 answer
Armstrong Numbers Between Two Integers
Java
0 vote109 views1 answer
How to create a udp protocol for transfer a big quantity of files java
Java
0 vote104 views1 answer
Empty string databinding android
Java
16 votes105 views2 answers
Java read file bufferedreader
Java
6 votes106 views2 answers
2d array length in java
Java
3 votes102 views1 answer
New in japanese
Java
4 votes109 views4 answers
Java while loop example
Java
5 votes115 views6 answers
Java exception handling
Java