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 vote137 views1 answer
Trivers json node as node type
Java
0 vote118 views2 answers
Registry
Java
1 vote108 views2 answers
Java compare char
Java
0 vote122 views1 answer
Stop countdown timer when exiting an activity
Java
5 votes111 views3 answers
Random string generator java
Java
0 vote113 views1 answer
Arraylist to linkedlist java
Java
0 vote117 views1 answer
Run jar with logback config file
Java
0 vote110 views1 answer
A Java-8 stream of batches,
Java
0 vote121 views1 answer
Java generate secure random password
Java
0 vote154 views1 answer
Java.lang.IllegalStateException: Not scheduled yet
Java