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 vote127 views2 answers
Fixed length array powershell
Java
0 vote133 views1 answer
Print 1 to 10 using thread in java
Java
8 votes120 views2 answers
Arraylist reverse in java
Java
9 votes127 views3 answers
Read file in java
Java
2 votes111 views2 answers
Kotlin variable in string
Java
0 vote130 views1 answer
Buy and sell stock
Java
0 vote133 views1 answer
12 hours to 24 hours java
Java
0 vote158 views1 answer
How to assign null to a variable in Java
Java
0 vote120 views1 answer
From double to float android studio
Java
0 vote122 views1 answer
Icon label java
Java