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 vote261 views1 answer
Viewresolver in spring boot
Java
5 votes251 views1 answer
Why java platform independent
Java
0 vote244 views2 answers
Java split string into list
Java
1 vote265 views1 answer
Get value of string java
Java
0 vote250 views1 answer
Spring delete objest from database that are not in your object list
Java
2 votes193 views1 answer
Java observable class
Java
7 votes254 views3 answers
Best programming language
Java
4 votes241 views1 answer
Find difference in days between two dates java
Java
0 vote266 views1 answer
Testing the web layer without authentication spring
Java
1 vote269 views1 answer
Runtime exception in java
Java