org.apache.hadoop.hbase.mapreduce

Class TsvImporterCustomTestMapper

java.lang.Object

<any>

org.apache.hadoop.hbase.mapreduce.TsvImporterMapper

org.apache.hadoop.hbase.mapreduce.TsvImporterCustomTestMapper

public class TsvImporterCustomTestMapper
extends TsvImporterMapper

Dummy mapper used for unit tests to verify that the mapper can be injected. This approach would be used if a custom transformation needed to be done after reading the input data before writing it to HFiles.

Field Summary

Fields inherited from class org.apache.hadoop.hbase.mapreduce.TsvImporterMapper

cellVisibilityExpr, conf, kvCreator, parser, ts, ttl

Constructor Summary

Constructors

Constructor and Description
TsvImporterCustomTestMapper()

Method Summary

Modifier and Type	Method and Description
void	map(LongWritable offset, Text value, Context context) Convert a line of TSV text into an HBase table row after transforming the values by multiplying them by 3.
protected void	setup(Context context) Handles initializing this class with objects specific to it (i.e., the parser).

Methods inherited from class org.apache.hadoop.hbase.mapreduce.TsvImporterMapper

doSetup, getBadLineCount, getSkipBadLines, getTs, incrementBadLineCount, populatePut

Methods inherited from class java.lang.Object

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

Constructor Detail

TsvImporterCustomTestMapper

public TsvImporterCustomTestMapper()

Method Detail

setup

protected void setup(Context context)

Description copied from class: TsvImporterMapper

Handles initializing this class with objects specific to it (i.e., the parser). Common initialization that might be leveraged by a subsclass is done in doSetup. Hence a subclass may choose to override this method and call doSetup as well before handling it's own custom params.

Overrides:

setup in class TsvImporterMapper

map

public void map(LongWritable offset,
                Text value,
                Context context)
         throws IOException

Convert a line of TSV text into an HBase table row after transforming the values by multiplying them by 3.

Overrides:

map in class TsvImporterMapper

Throws:

IOException