Package org.apache.hadoop.hbase.mapreduce

Class Import.CellImporter

java.lang.Object

org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,KEYOUT,VALUEOUT>

org.apache.hadoop.hbase.mapreduce.TableMapper<ImmutableBytesWritable,Cell>

org.apache.hadoop.hbase.mapreduce.Import.CellImporter

Enclosing class:

Import

public static class Import.CellImporter
extends TableMapper<ImmutableBytesWritable,Cell>

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

Field Summary

Fields

Modifier and Type	Field	Description
private Map<byte[],byte[]>	cfRenameMap
private Filter	filter
private static final org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor	Description
CellImporter()

Method Summary

Modifier and Type	Method	Description
void	map(ImmutableBytesWritable row, Result value, org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,Cell>.org.apache.hadoop.mapreduce.Mapper.Context context)
void	setup(org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,Cell>.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

Field Details

cfRenameMap

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

filter

private Filter filter

LOG

private static final org.slf4j.Logger LOG

Constructor Details

CellImporter

public CellImporter()

Method Details

map

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

Overrides:

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

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<ImmutableBytesWritable,Result,ImmutableBytesWritable,Cell>.org.apache.hadoop.mapreduce.Mapper.Context context)

Overrides:

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