ScaleOut hServer Java Programmer's Guide
Storing input/output data sets in the IMDG

The NamedMapInputFormat reads all the entries from the named map and sends the keys and values it retrieves to the mappers.

The input named map should be set as a configuration property by calling setNamedMap(…).

The following example illustrates how to use NamedMapInputFormat and associate it with a named map within the IMDG:

//Create the named map
NamedMap<Integer, String> namedMap = NamedMapFactory.getMap("myMap");
namedMap.clear();

//Insert entries - do a bulk put for better performance
BulkLoader<Integer, String> loader = namedMap.getBulkLoader();
for(int i=0; i<1000000; i++)
{
    loader.put(i, "initial.value");
}
loader.close();

//Set up the job
Job job = new HServerJob(new Configuration());
// ...
job.setInputFormatClass(NamedMapInputFormat.class);
NamedMapInputFormat.setNamedMap(job, namedMap);