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 vote174 views2 answers
Convert int to ascii java
Java
2 votes141 views1 answer
Nginx change root directory
Java
0 vote211 views1 answer
How to get data from array list to set java
Java
1 vote176 views1 answer
Java swing make window not resizable
Java
0 vote143 views1 answer
Force_dark_auto android webview
Java
0 vote143 views1 answer
Intent- setaction FOR FILES
Java
32 votes194 views3 answers
Java foreach method
Java
0 vote169 views1 answer
Convert character digit to int java
Java
0 vote148 views1 answer
Java komplettes array ausgeben
Java
0 vote191 views1 answer
Spring boot procfile run profile
Java Spring