Import.KeyValueImporter (Cloud Bigtable HBase Client for Java 1.12.0 API)

com.google.cloud.bigtable.mapreduce

Class Import.KeyValueImporter

• java.lang.Object
• • org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,KEYOUT,VALUEOUT>
  • • org.apache.hadoop.hbase.mapreduce.TableMapper<ImmutableBytesWritable,KeyValue>
    • • com.google.cloud.bigtable.mapreduce.Import.KeyValueImporter

• Enclosing class:

  Import

  ---

  
  

  public static class Import.KeyValueImporter
  extends TableMapper<ImmutableBytesWritable,KeyValue>

  A mapper that just writes out KeyValues.

• • Nested Class Summary

    • Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.Mapper

      org.apache.hadoop.mapreduce.Mapper.Context

  • Constructor Summary

    Constructors 

    Constructor and Description
    KeyValueImporter()

  • Method Summary

    All Methods Instance Methods Concrete Methods 

    Modifier and Type	Method and Description
    void	map(ImmutableBytesWritable row, Result value, org.apache.hadoop.mapreduce.Mapper.Context context)
    void	setup(org.apache.hadoop.mapreduce.Mapper.Context context)

    • Methods inherited from class org.apache.hadoop.mapreduce.Mapper

      cleanup, run

    • Methods inherited from class java.lang.Object

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

• • Constructor Detail

    • KeyValueImporter

      public KeyValueImporter()

  • Method Detail

    • map

      public void map(ImmutableBytesWritable row,
                      Result value,
                      org.apache.hadoop.mapreduce.Mapper.Context context)
               throws IOException

      Overrides:

      map in class org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,KeyValue>

      Parameters:

      row - The current table row key.

      value - The columns.

      context - The current context.

      Throws:

      IOException - When something is broken with the data.

    • setup

      public void setup(org.apache.hadoop.mapreduce.Mapper.Context context)

      Overrides:

      setup in class org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,KeyValue>