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 vote390 views1 answer
How to draw
Java
0 vote377 views1 answer
How to add value in jcombobox in java
Java
0 vote360 views1 answer
Given an int variable n that has already been declared and initialized to a positive value, use a do...while loop to print a single line consisting of n asterisks. Use no variables other than n.
Java
0 vote338 views1 answer
C:\elastic stack\elasticsearch-7.15.1-windows-x86_64\elasticsearch-7.15.1\bin>java -version java version "1.8.0_311" Java(TM) SE Runtime Environment (build 1.8.0_311-b11) Java HotSpot(TM) Client VM (build 25.311-b11, mixed mode, sharing)
Java
-1 vote343 views1 answer
Testng with cucumber
Java
0 vote334 views1 answer
How to find length of string array java
Java
1 vote356 views1 answer
Joptionpane hello world
Java
0 vote366 views2 answers
Java explicit array declaration
Java
38 votes387 views4 answers
Math.random java between 1 and 10
Java
0 vote347 views1 answer
RNGestureHandlerButtonViewManager.java uses or overrides a deprecated API
Java