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 vote209 views1 answer
Display an image java
Java
0 vote168 views1 answer
Aws s3 compatible java
Java
0 vote180 views1 answer
Android studio get id name from view
Java
0 vote186 views1 answer
Show input dialog java
Java
1 vote212 views1 answer
String by byte array in java
Java
5 votes169 views2 answers
Abstraction in java
Java
0 vote159 views1 answer
What isz meaning of EL in jsp
Java
0 vote192 views1 answer
Java commands in different packages not working
Java
2 votes179 views1 answer
Android list[i]
Java
0 vote170 views1 answer
Java instanciar objeto File
Java