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 vote270 views1 answer
Scanner check if int
Java
0 vote249 views1 answer
How to check size of arrayin java
Java
2 votes236 views1 answer
Action on boutton click java swing
Java
0 vote244 views1 answer
Java namespaces
Java
0 vote253 views1 answer
How to declare and allocate memory to array in java
Java
3 votes230 views1 answer
Android array list length
Java
2 votes261 views1 answer
Prendere valore da tastiera java
Java
0 vote228 views1 answer
Java array with objects from different types
Java
0 vote229 views1 answer
Java.lang.nullpointerexception: attempt to invoke virtual method 'long java.lang.long.longvalue()' on a null object reference
Java
0 vote232 views1 answer
LocalRegistry java rebind() java8
Java