public class TableMutationRecordWriter
extends org.apache.hadoop.mapreduce.RecordWriter<com.mapr.db.mapreduce.impl.ByteBufWritableComparable,org.ojai.store.DocumentMutation>
Constructor and Description |
---|
TableMutationRecordWriter(com.mapr.db.Table t) |
Modifier and Type | Method and Description |
---|---|
void |
close(org.apache.hadoop.mapreduce.TaskAttemptContext context)
Closes the writer, in this case flush table commits.
|
void |
write(com.mapr.db.mapreduce.impl.ByteBufWritableComparable key,
org.ojai.store.DocumentMutation value)
Writes a key/value pair into the table.
|
public void write(com.mapr.db.mapreduce.impl.ByteBufWritableComparable key, org.ojai.store.DocumentMutation value) throws IOException, InterruptedException
write
in class org.apache.hadoop.mapreduce.RecordWriter<com.mapr.db.mapreduce.impl.ByteBufWritableComparable,org.ojai.store.DocumentMutation>
key
- The key.value
- The value.IOException
- When writing fails.InterruptedException
RecordWriter.write(java.lang.Object, java.lang.Object)
public void close(org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
close
in class org.apache.hadoop.mapreduce.RecordWriter<com.mapr.db.mapreduce.impl.ByteBufWritableComparable,org.ojai.store.DocumentMutation>
context
- The context.IOException
- When closing the writer fails.InterruptedException
RecordWriter.close(org.apache.hadoop.mapreduce.TaskAttemptContext)
Copyright © 2016 Mapr Technologies, Inc.. All rights reserved.