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

7 votes191 views1 answer
Byte java
Java
4 votes199 views5 answers
Java main method
Java
4 votes183 views1 answer
How to change theme of app in android studio programmatically
Java
10 votes180 views6 answers
Java Print
Java
37 votes302 views1 answer
Java hashmap entryset
Java
1 vote175 views1 answer
Filesaver javafx
Java
0 vote180 views1 answer
DMC5 performace mod
Java
0 vote196 views1 answer
Java get current machine's IP address
Java
0 vote198 views1 answer
How to take array as an argument in java
Java
0 vote181 views1 answer
Java program to print 1 to 100 using for loop
Java