public class BulkLoadOutputFormat
extends org.apache.hadoop.mapreduce.OutputFormat<org.ojai.Value,org.ojai.Document>
implements org.apache.hadoop.conf.Configurable
Modifier and Type | Field and Description |
---|---|
static String |
OUTPUT_TABLE |
Constructor and Description |
---|
BulkLoadOutputFormat() |
Modifier and Type | Method and Description |
---|---|
void |
checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext context) |
org.apache.hadoop.conf.Configuration |
getConf()
Returns current configuration object.
|
org.apache.hadoop.mapreduce.OutputCommitter |
getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
Return the outputCommitter object.
|
static List<ByteBuffer> |
getPartitionSplitPoints(String tabName)
Returns a list of keys which indicate the starting of each input partition.
|
org.apache.hadoop.mapreduce.RecordWriter<org.ojai.Value,org.ojai.Document> |
getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
Returns a bulkload RecordWriter object which can write a row to a table.
|
void |
setConf(org.apache.hadoop.conf.Configuration conf)
Sets parameters in current configuration.
|
public static final String OUTPUT_TABLE
public void setConf(org.apache.hadoop.conf.Configuration conf)
setConf
in interface org.apache.hadoop.conf.Configurable
conf
- Current configuration.Configurable.setConf(org.apache.hadoop.conf.Configuration)
public org.apache.hadoop.conf.Configuration getConf()
getConf
in interface org.apache.hadoop.conf.Configurable
Configurable.getConf()
public org.apache.hadoop.mapreduce.RecordWriter<org.ojai.Value,org.ojai.Document> getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
getRecordWriter
in class org.apache.hadoop.mapreduce.OutputFormat<org.ojai.Value,org.ojai.Document>
context
- current job context.IOException
InterruptedException
public void checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext context) throws IOException, InterruptedException
checkOutputSpecs
in class org.apache.hadoop.mapreduce.OutputFormat<org.ojai.Value,org.ojai.Document>
IOException
InterruptedException
public org.apache.hadoop.mapreduce.OutputCommitter getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
getOutputCommitter
in class org.apache.hadoop.mapreduce.OutputFormat<org.ojai.Value,org.ojai.Document>
context
- current job context.IOException
InterruptedException
OutputFormat.getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext)
public static List<ByteBuffer> getPartitionSplitPoints(String tabName) throws IOException
tabName
- output table Name.IOException
Copyright © 2016 Mapr Technologies, Inc.. All rights reserved.