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 vote330 views2 answers
Java Program to Convert Milliseconds to Minutes and Seconds
Java
0 vote356 views1 answer
Java sealed class
Java
0 vote328 views1 answer
Adding matrix
Java
1 vote356 views2 answers
Get epoch time in java
Java
1 vote327 views6 answers
Java code to c code converter online
Java
1 vote352 views1 answer
Java map values to list
Java
0 vote356 views1 answer
How to print message to console java
Java
2 votes329 views2 answers
Android studio print console
Java
1 vote347 views1 answer
Javafx textarea new line with shift+enter
Java
2 votes354 views1 answer
Java programming language
Java