public class TableRecordWriter
extends org.apache.hadoop.mapreduce.RecordWriter<org.ojai.Value,org.ojai.Document>
Modifier and Type | Field and Description |
---|---|
static String |
OUTPUT_TABLE
Job parameter that specifies the output table.
|
Constructor and Description |
---|
TableRecordWriter(com.mapr.db.Table table) |
public static final String OUTPUT_TABLE
public void close(org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException
close
in class org.apache.hadoop.mapreduce.RecordWriter<org.ojai.Value,org.ojai.Document>
context
- The context.IOException
- When closing the writer fails.RecordWriter.close(org.apache.hadoop.mapreduce.TaskAttemptContext)
public void write(org.ojai.Value key, org.ojai.Document value) throws IOException
write
in class org.apache.hadoop.mapreduce.RecordWriter<org.ojai.Value,org.ojai.Document>
key
- The key.value
- The value.IOException
- When writing fails.RecordWriter.write(java.lang.Object, java.lang.Object)
Copyright © 2016 Mapr Technologies, Inc.. All rights reserved.