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 vote183 views1 answer
Spring boot jpa in clause
Java Spring
0 vote146 views1 answer
Short array in java
Java
2 votes194 views2 answers
Spring boot connect to xampp mysql
Java
26 votes143 views3 answers
Java random between
Java
3 votes163 views2 answers
Android round double to 2 decimal
Java
0 vote298 views1 answer
Hashmap values sum java
Java
0 vote170 views2 answers
How to add background color in jframe
Java
0 vote141 views1 answer
List all android sensors in java
Java
0 vote131 views1 answer
Set image programmatically android
Java
2 votes149 views1 answer
Android translate string java
Java