org.apache.gora.mapreduce

Class GoraMapReduceUtils

java.lang.Object

org.apache.gora.mapreduce.GoraMapReduceUtils

public class GoraMapReduceUtils
extends Object

MapReduce related utilities for Gora

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GoraMapReduceUtils.HelperInputFormat<K,V>

Constructor Summary

Constructors

Constructor and Description
GoraMapReduceUtils()

Method Summary

Methods

Modifier and Type	Method and Description
static org.apache.hadoop.mapreduce.JobContext	createJobContext(org.apache.hadoop.conf.Configuration conf, String inputPath)
static List<org.apache.hadoop.mapreduce.InputSplit>	getSplits(org.apache.hadoop.conf.Configuration conf, String inputPath)
static void	setIOSerializations(org.apache.hadoop.conf.Configuration conf, boolean reuseObjects) Add our own serializer (obtained via the PersistentSerialization wrapper) to any other io.serializations which may be specified within existing Hadoop configuration.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GoraMapReduceUtils

public GoraMapReduceUtils()

Method Detail

setIOSerializations

public static void setIOSerializations(org.apache.hadoop.conf.Configuration conf,
                       boolean reuseObjects)

Add our own serializer (obtained via the PersistentSerialization wrapper) to any other io.serializations which may be specified within existing Hadoop configuration.

Parameters:

conf - the Hadoop configuration object

reuseObjects - boolean parameter to reuse objects

getSplits

public static List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.conf.Configuration conf,
                                                     String inputPath)
                                                              throws IOException

Throws:

IOException

createJobContext

public static org.apache.hadoop.mapreduce.JobContext createJobContext(org.apache.hadoop.conf.Configuration conf,
                                                      String inputPath)
                                                               throws IOException

Throws:

IOException