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

2 votes131 views2 answers
Format localdatetime
Java
0 vote175 views1 answer
Java date add hours
Java
66 votes156 views3 answers
Split String regex java
Java
0 vote144 views1 answer
Java while loop q to quit
Java
1 vote99 views1 answer
Read a file in java and store as integer array using buffered reader
Java
10 votes172 views2 answers
Navigate to another activity in android
Java
16 votes116 views2 answers
Java random usage
Java
4 votes132 views2 answers
Dfhgodjfgiojdfiojgjkdhjbsdv JKNJZXcnmvmcvbpdfh
Java
3 votes149 views2 answers
Counting repeated characters in a string in java
Java
0 vote147 views1 answer
Creating jdbc connection in java using service name oracle
Java