public class BulkLoadRecordWriter
extends org.apache.hadoop.mapreduce.RecordWriter<org.ojai.Value,org.ojai.Document>
Constructor and Description |
---|
BulkLoadRecordWriter(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.Path tablePath) |
Modifier and Type | Method and Description |
---|---|
void |
close(org.apache.hadoop.mapreduce.TaskAttemptContext c) |
void |
write(org.ojai.Value rowKey,
org.ojai.Document record)
Writes a document to the table.
|
void |
write(org.ojai.Value idValue,
org.ojai.store.DocumentMutation mutation)
Writes a record mutation to the table.
|
public BulkLoadRecordWriter(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path tablePath) throws java.io.IOException, com.mapr.db.exceptions.TableNotFoundException
java.io.IOException
com.mapr.db.exceptions.TableNotFoundException
public void write(org.ojai.Value idValue, org.ojai.store.DocumentMutation mutation) throws java.io.IOException, java.lang.InterruptedException, java.lang.NullPointerException
idValue
- rowkey in the table.mutation
- mutation to be updated in the table.java.io.IOException
java.lang.InterruptedException
java.lang.NullPointerException
public void write(org.ojai.Value rowKey, org.ojai.Document record) throws java.io.IOException, java.lang.InterruptedException, java.lang.NullPointerException
write
in class org.apache.hadoop.mapreduce.RecordWriter<org.ojai.Value,org.ojai.Document>
rowKey
- rowkey to be written to the table.record
- document to be written.java.io.IOException
java.lang.InterruptedException
java.lang.NullPointerException
public void close(org.apache.hadoop.mapreduce.TaskAttemptContext c) throws java.io.IOException, java.lang.InterruptedException
close
in class org.apache.hadoop.mapreduce.RecordWriter<org.ojai.Value,org.ojai.Document>
java.io.IOException
java.lang.InterruptedException