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 vote325 views1 answer
Enum with numbers java
Java
0 vote342 views1 answer
Java mail use tls 1.2
Java
31 votes341 views5 answers
Thread.sleep
Java
2 votes285 views2 answers
Java class initialization
Java
1 vote313 views4 answers
C code to java converter
Java
0 vote336 views1 answer
Lcm of two large positive integers java
Java
-3 votes347 views2 answers
Multiplication table for number Java
Java
3 votes305 views1 answer
How can i to do java home
Java
1 vote327 views2 answers
Komplettes array ausgeben java
Java
4 votes316 views2 answers
Number of lines in file java
Java