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

static class

GoraMapReduceUtils.HelperInputFormat<K,V>

Constructor Summary

GoraMapReduceUtils()

Method Summary

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)

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)

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