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 vote198 views1 answer
Java Tiempo transcurrido entre fechas y horas
Java
0 vote256 views1 answer
Java.lang.noclassdeffounderror: failed resolution of: lorg/apache/http/protocolversion;
Java
0 vote187 views1 answer
Android Gradle plugin requires Java 11 to run. You are currently using Java 1.8.
Java
0 vote244 views1 answer
How to use random bound on doubles java
Java
1 vote190 views1 answer
Why can we implement multiple interfaces
Java
1 vote180 views1 answer
Convert pdf to word in java
Java
0 vote202 views1 answer
Exception in Application start method java.lang.reflect.InvocationTargetException
Java
0 vote191 views1 answer
Gcd = 1
Java
1 vote202 views1 answer
Spring gradle don't build boot jar
Java
0 vote216 views1 answer
Java integer division to float
Java