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 java.lang.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 java.util.List<java.nio.ByteBuffer> |
getPartitionSplitPoints(java.lang.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 java.lang.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 java.io.IOException, java.lang.InterruptedException
getRecordWriter
in class org.apache.hadoop.mapreduce.OutputFormat<org.ojai.Value,org.ojai.Document>
context
- current job context.java.io.IOException
java.lang.InterruptedException
public void checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext context) throws java.io.IOException, java.lang.InterruptedException
checkOutputSpecs
in class org.apache.hadoop.mapreduce.OutputFormat<org.ojai.Value,org.ojai.Document>
java.io.IOException
java.lang.InterruptedException
public org.apache.hadoop.mapreduce.OutputCommitter getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context) throws java.io.IOException, java.lang.InterruptedException
getOutputCommitter
in class org.apache.hadoop.mapreduce.OutputFormat<org.ojai.Value,org.ojai.Document>
context
- current job context.java.io.IOException
java.lang.InterruptedException
OutputFormat.getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext)
public static java.util.List<java.nio.ByteBuffer> getPartitionSplitPoints(java.lang.String tabName) throws java.io.IOException
tabName
- output table Name.java.io.IOException