Field Detail

• connection

  private Connection connection

• mutator

  private BufferedMutator mutator

Constructor Detail

• TableOutputFormat.TableRecordWriter

  public TableOutputFormat.TableRecordWriter()
                                      throws IOException

  Throws:

  IOException

Method Detail

• close

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

  Closes the writer, in this case flush table commits.

  Specified by:

  close in class org.apache.hadoop.mapreduce.RecordWriter<KEY,Mutation>

  Parameters:

  context - The context.

  Throws:

  IOException - When closing the writer fails.

  See Also:

  RecordWriter.close(TaskAttemptContext)

• write

  public void write(KEY key,
           Mutation value)
             throws IOException

  Writes a key/value pair into the table.

  Specified by:

  write in class org.apache.hadoop.mapreduce.RecordWriter<KEY,Mutation>

  Parameters:

  key - The key.

  value - The value.

  Throws:

  IOException - When writing fails.

  See Also:

  RecordWriter.write(Object, Object)