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 vote323 views1 answer
Java logger with different colors
Java
0 vote345 views1 answer
Console java
Java
4 votes296 views1 answer
Disable button java
Java
1 vote323 views1 answer
Recompile with -Xlint:deprecation
Java
0 vote337 views1 answer
Hide steam games from friends
Java
1 vote421 views1 answer
Maven source option 5 is no longer supported use 7 or later
Java
0 vote332 views1 answer
How to initialize a string in java
Java
3 votes276 views1 answer
Java jdk set path windows 10
Java
5 votes311 views1 answer
How to get the width and height of a string in java
Java
0 vote328 views1 answer
Bad notification for startForeground: java.lang.RuntimeException: invalid
Java