com.mapr.db.mapreduce

Class TableMutationRecordWriter

java.lang.Object

org.apache.hadoop.mapreduce.RecordWriter<org.ojai.Value,org.ojai.store.DocumentMutation>

com.mapr.db.mapreduce.TableMutationRecordWriter

public class TableMutationRecordWriter
extends org.apache.hadoop.mapreduce.RecordWriter<org.ojai.Value,org.ojai.store.DocumentMutation>

Receives a Record Mutation from Map/Reduce phase and writes to a JSON table.

Constructor Summary

Constructors

Constructor and Description
TableMutationRecordWriter(com.mapr.db.Table t)

Method Summary

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(org.ojai.Value key, org.ojai.store.DocumentMutation value) Updates a row given by the key in the table with DocumentMutation.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TableMutationRecordWriter

public TableMutationRecordWriter(com.mapr.db.Table t)

Method Detail

write

public void write(org.ojai.Value key,
                  org.ojai.store.DocumentMutation value)
           throws java.io.IOException,
                  java.lang.InterruptedException

Updates a row given by the key in the table with DocumentMutation.

Specified by:

write in class org.apache.hadoop.mapreduce.RecordWriter<org.ojai.Value,org.ojai.store.DocumentMutation>

Parameters:

key - The key.

value - DocumentMutation to be used for update.

Throws:

java.io.IOException - When writing fails.

java.lang.InterruptedException

See Also:

RecordWriter.write(java.lang.Object, java.lang.Object)

close

public void close(org.apache.hadoop.mapreduce.TaskAttemptContext context)
           throws java.io.IOException,
                  java.lang.InterruptedException

Closes the writer, in this case flush table commits.

Specified by:

close in class org.apache.hadoop.mapreduce.RecordWriter<org.ojai.Value,org.ojai.store.DocumentMutation>

Parameters:

context - The context.

Throws:

java.io.IOException - When closing the writer fails.

java.lang.InterruptedException

See Also:

RecordWriter.close(org.apache.hadoop.mapreduce.TaskAttemptContext)