Package org.apache.hadoop.hbase.mapreduce

Class Import.CellSortImporter

java.lang.Object

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

org.apache.hadoop.hbase.mapreduce.TableMapper<Import.CellWritableComparable,Cell>

org.apache.hadoop.hbase.mapreduce.Import.CellSortImporter

Enclosing class:

Import

public static class Import.CellSortImporter
extends TableMapper<Import.CellWritableComparable,Cell>

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
CellSortImporter()

Method Summary

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

CellSortImporter

public CellSortImporter()

Method Details

map

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

Overrides:

map in class org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,Import.CellWritableComparable,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,Import.CellWritableComparable,Cell>.org.apache.hadoop.mapreduce.Mapper.Context context)
           throws IOException

Overrides:

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

Throws:

IOException