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

3 votes84 views1 answer
How to check a integer in java
Java
3 votes128 views1 answer
Pi in java
Java
1 vote118 views1 answer
Recompile with -Xlint:deprecation
Java
0 vote116 views1 answer
équivalent setTimeInterval java
Java
11 votes118 views1 answer
Java stack methods
Java
0 vote128 views2 answers
Sha1
Java
0 vote117 views1 answer
16 kare koku 4 in java
Java
0 vote117 views2 answers
How to insert a char at n position java
Java
6 votes119 views6 answers
Do while loop in java
Java
53 votes142 views6 answers
Get last index of array java
Java