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 vote292 views1 answer
ERROR: Failed to resolve: com.github.HaarigerHarald:android-youtubeExtractor:v1.7.0
Java
13 votes268 views3 answers
How to convert double to int in java
Java
1 vote274 views2 answers
Android change checkbox color
Java
0 vote273 views1 answer
Gat environment variables java
Java
0 vote273 views1 answer
/= java
Java
16 votes259 views2 answers
Java how to reverse an array
Java
-1 vote282 views6 answers
What is java
Java
1 vote275 views1 answer
Has integer java
Java
0 vote302 views1 answer
Simple text formatter as in textbook
Java
29 votes298 views6 answers
Reverse a string in java
Java