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 vote238 views1 answer
Spring mvc aop transaction management
Java Spring
0 vote212 views1 answer
Usaco 2018 january contest
Java
15 votes210 views10 answers
Hello world
Java
0 vote209 views1 answer
Private access modifiers
Java
1 vote153 views1 answer
Beanutils.copyproperties exclude properties
Java
0 vote167 views1 answer
Number to int java
Java
1 vote192 views1 answer
Powershell.exe location
Java
0 vote195 views1 answer
Java remove duplicates from list by property
Java
0 vote198 views1 answer
Error inflating class android.support.design.widget.CoordinatorLayout
Java
2 votes242 views1 answer
How to set frame colo in java
Java