public class MapRDBMapReduceUtil
extends java.lang.Object
Constructor and Description |
---|
MapRDBMapReduceUtil() |
Modifier and Type | Method and Description |
---|---|
static void |
configureMutationOutputFormat(org.apache.hadoop.mapreduce.Job job,
java.lang.String destTable)
Utility function to set up TableMutationOutputFormat if user wants to send DocumentMutation
to update existing documents in a MapRDB table.
|
static int |
configurePartitioner(org.apache.hadoop.mapreduce.Job job,
java.lang.String destPath)
Utility function that is used to set up custom partitioner for MapR-DB destination tables.
|
static void |
configureTableInputFormat(org.apache.hadoop.mapreduce.Job job,
java.lang.String srcTable)
This function is called to configure table input format to read data from MapR-DB
table into a MapReduce application.
|
static void |
configureTableOutputFormat(org.apache.hadoop.mapreduce.Job job,
java.lang.String destTable)
This function is invoked to configure the table output format for MapReduce application.
|
static void |
setMapOutputKeyValueClass(org.apache.hadoop.mapreduce.Job job)
Function to be used to set Map Output Key class if an intermediate stage (Map/Reduce) will
emit value (as key) and Document (as value).
|
static void |
setOutputKeyValueClass(org.apache.hadoop.mapreduce.Job job)
Function to be used to set Output Key class if an intermediate stage (Map/Reduce) will
emit value (as key) and Document (as value).
|
public static void configureTableInputFormat(org.apache.hadoop.mapreduce.Job job, java.lang.String srcTable) throws java.io.IOException
job
- MapReduce job object.srcTable
- Name of the source table.java.io.IOException
public static void configureTableOutputFormat(org.apache.hadoop.mapreduce.Job job, java.lang.String destTable)
job
- MapReduce job object.destTable
- Name of the destination table.public static void configureMutationOutputFormat(org.apache.hadoop.mapreduce.Job job, java.lang.String destTable)
job
- MapReduce job object.destTable
- Name of the destination table.public static void setMapOutputKeyValueClass(org.apache.hadoop.mapreduce.Job job)
job
- public static void setOutputKeyValueClass(org.apache.hadoop.mapreduce.Job job)
job
- public static int configurePartitioner(org.apache.hadoop.mapreduce.Job job, java.lang.String destPath) throws java.io.IOException
job
- MapReduce job object.destPath
- Destination table for M/R job.java.io.IOException