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 vote132 views1 answer
Java sort reverse lambda
Java
0 vote214 views1 answer
@crossorigin spring allow all
Java
0 vote136 views1 answer
Using new to create arrays
Java
6 votes123 views5 answers
Max of an array java
Java
0 vote155 views1 answer
Autowired in spring boot error creating bean with name
Java Spring
0 vote123 views1 answer
Jbutton open jframe java
Java
0 vote95 views1 answer
How to hide complete layout in xml android studio
Java
0 vote150 views1 answer
Error creating bean with name 'org.springframework.cloud.netflix.eureka.server.EurekaServerInitializerConfiguration'
Java Spring
1 vote145 views1 answer
Convert ASCII to String Java
Java
10 votes140 views5 answers
Sort 2d array by column java
Java