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 vote194 views1 answer
Kotlin android intent pass data
Java
13 votes235 views2 answers
For loop in java example complete programs
Java
0 vote197 views1 answer
Console java echo hello you
Java
0 vote183 views1 answer
Your application is missing a valid safety identifier
Java
0 vote209 views1 answer
Could not get JDBC Connection; nested exception is java.sql.SQLException: Access denied for user 'hac_manager'@'localhost' (using password: YES)
Java
0 vote194 views2 answers
How to make it another player's turn java
Java
-1 vote230 views2 answers
Calculating the percentile in java
Java
0 vote204 views1 answer
Netbeans android sdk location
Java
0 vote194 views1 answer
Font type javafx button css
Java
0 vote196 views1 answer
Double to string java stack overflow
Java