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 vote452 views1 answer
Spring websocket allow origin
Java Spring
0 vote292 views1 answer
Convertir un float en int en java
Java
11 votes261 views1 answer
Java one line if else
Java
4 votes286 views2 answers
How to add to a file in java
Java
0 vote289 views1 answer
Javafx change textfield background color
Java
13 votes305 views5 answers
Android sharedpreferences
Java
0 vote290 views1 answer
Como calcular a raiz quadrada em java
Java
0 vote282 views1 answer
Java get JComboBox value
Java
1 vote286 views4 answers
How to create progress dialog programmatically in android
Java
6 votes272 views1 answer
Arrays sort 2d array java
Java