Package org.apache.accumulo.core.client.mapreduce

Class AccumuloOutputFormat.AccumuloRecordWriter

java.lang.Object
org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.Text,Mutation>
org.apache.accumulo.core.client.mapreduce.AccumuloOutputFormat.AccumuloRecordWriter
Enclosing class:
AccumuloOutputFormat
protected static class AccumuloOutputFormat.AccumuloRecordWriter extends org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.Text,Mutation>
A base class to be used to create RecordWriter instances that write to Accumulo.

  • Constructor Summary

    Constructors
    Modifier
    Constructor
    Description
    protected
    AccumuloRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    addTable(org.apache.hadoop.io.Text tableName)
     
    void
    close(org.apache.hadoop.mapreduce.TaskAttemptContext attempt)
     
    void
    write(org.apache.hadoop.io.Text table, Mutation mutation)
    Push a mutation into a table.

    Methods inherited from class java.lang.Object

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