Package org.apache.hadoop.hbase.mapreduce

Class TsvImporterCustomTestMapperForOprAttr

java.lang.Object

org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Put>

org.apache.hadoop.hbase.mapreduce.TsvImporterMapper

org.apache.hadoop.hbase.mapreduce.TsvImporterCustomTestMapperForOprAttr

public class TsvImporterCustomTestMapperForOprAttr
extends org.apache.hadoop.hbase.mapreduce.TsvImporterMapper

Just shows a simple example of how the attributes can be extracted and added to the puts

Nested Class Summary

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

org.apache.hadoop.mapreduce.Mapper.Context

Field Summary

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

cellVisibilityExpr, conf, kvCreator, parser, ts, ttl

Constructor Summary

Constructors

Constructor	Description
TsvImporterCustomTestMapperForOprAttr()

Method Summary

Modifier and Type	Method	Description
private String	msg(Object[] attributes)
protected void	populatePut(byte[] lineBytes, org.apache.hadoop.hbase.mapreduce.ImportTsv.TsvParser.ParsedLine parsed, org.apache.hadoop.hbase.client.Put put, int i)

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

doSetup, getBadLineCount, getSkipBadLines, getTs, incrementBadLineCount, map, setup

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 Details

TsvImporterCustomTestMapperForOprAttr

public TsvImporterCustomTestMapperForOprAttr()

Method Details

populatePut

protected void populatePut(byte[] lineBytes,
 org.apache.hadoop.hbase.mapreduce.ImportTsv.TsvParser.ParsedLine parsed,
 org.apache.hadoop.hbase.client.Put put,
 int i)
                    throws org.apache.hadoop.hbase.mapreduce.ImportTsv.TsvParser.BadTsvLineException,
IOException

Overrides:

populatePut in class org.apache.hadoop.hbase.mapreduce.TsvImporterMapper

Throws:

org.apache.hadoop.hbase.mapreduce.ImportTsv.TsvParser.BadTsvLineException

IOException

msg

private String msg(Object[] attributes)