public class MapRDBMapReduceUtil extends Object
Constructor and Description |
---|
MapRDBMapReduceUtil() |
Modifier and Type | Method and Description |
---|---|
static int |
configurePartitioner(org.apache.hadoop.mapreduce.Job job,
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,
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,
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, String srcTable) throws IOException
job
- MapReduce job object.srcTable
- Name of the source table.IOException
public static void configureTableOutputFormat(org.apache.hadoop.mapreduce.Job job, 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, String destPath) throws IOException
job
- MapReduce job object.destPath
- Destination table for M/R job.IOException
Copyright © 2016 Mapr Technologies, Inc.. All rights reserved.