Field Detail

• LOG

  private static final org.apache.commons.logging.Log LOG

• connection

  Connection connection

• mutatorMap

  Map<ImmutableBytesWritable,BufferedMutator> mutatorMap

• conf

  org.apache.hadoop.conf.Configuration conf

• useWriteAheadLogging

  boolean useWriteAheadLogging

Constructor Detail

• MultiTableOutputFormat.MultiTableRecordWriter

  public MultiTableOutputFormat.MultiTableRecordWriter(org.apache.hadoop.conf.Configuration conf,
                                               boolean useWriteAheadLogging)

  Parameters:

  conf - HBaseConfiguration to used

  useWriteAheadLogging - whether to use write ahead logging. This can be turned off ( false) to improve performance when bulk loading data.

Method Detail

• getBufferedMutator

  BufferedMutator getBufferedMutator(ImmutableBytesWritable tableName)
                               throws IOException

  Parameters:

  tableName - the name of the table, as a string

  Returns:

  the named mutator

  Throws:

  IOException - if there is a problem opening a table

• close

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

  Specified by:

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

  Throws:

  IOException

• write

  public void write(ImmutableBytesWritable tableName,
           Mutation action)
             throws IOException

  Writes an action (Put or Delete) to the specified table.

  Specified by:

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

  Parameters:

  tableName - the table being updated.

  action - the update, either a put or a delete.

  Throws:

  IllegalArgumentException - if the action is not a put or a delete.

  IOException