com.mapr.db.mapreduce

Class TableRecordWriter

java.lang.Object

org.apache.hadoop.mapreduce.RecordWriter<org.ojai.Value,org.ojai.Document>

com.mapr.db.mapreduce.TableRecordWriter

public class TableRecordWriter
extends org.apache.hadoop.mapreduce.RecordWriter<org.ojai.Value,org.ojai.Document>

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

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	OUTPUT_TABLE Job parameter that specifies the output table.

Constructor Summary

Constructors

Constructor and Description
TableRecordWriter(com.mapr.db.Table table)

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.Document value) Writes a key/value pair into the table.

Methods inherited from class java.lang.Object

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

Field Detail

OUTPUT_TABLE

public static final java.lang.String OUTPUT_TABLE

Job parameter that specifies the output table.

See Also:

Constant Field Values

Constructor Detail

TableRecordWriter

public TableRecordWriter(com.mapr.db.Table table)

Method Detail

close

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

Closes the writer, in this case flush table commits.

Specified by:

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

Parameters:

context - The context.

Throws:

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

See Also:

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

write

public void write(org.ojai.Value key,
                  org.ojai.Document value)
           throws java.io.IOException

Writes a key/value pair into the table.

Specified by:

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

Parameters:

key - The key.

value - The value.

Throws:

java.io.IOException - When writing fails.

See Also:

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