Field Detail

• cfRenameMap

  private Map<byte[],byte[]> cfRenameMap

• clusterIds

  private List<UUID> clusterIds

• filter

  private Filter filter

• durability

  private Durability durability

Constructor Detail

• Import.Importer

  public Import.Importer()

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,Mutation>

  Parameters:

  row - The current table row key.

  value - The columns.

  context - The current context.

  Throws:

  IOException - When something is broken with the data.

• writeResult

  private void writeResult(ImmutableBytesWritable key,
                 Result result,
                 org.apache.hadoop.mapreduce.Mapper.Context context)
                    throws IOException,
                           InterruptedException

  Throws:

  IOException

  InterruptedException

• processKV

  protected void processKV(ImmutableBytesWritable key,
               Result result,
               org.apache.hadoop.mapreduce.Mapper.Context context,
               Put put,
               Delete delete)
                    throws IOException,
                           InterruptedException

  Throws:

  IOException

  InterruptedException

• addPutToKv

  protected void addPutToKv(Put put,
                Cell kv)
                     throws IOException

  Throws:

  IOException

• setup

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

  Overrides:

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