Package org.apache.hadoop.hbase.mapreduce

Class TestTimeRangeMapRed.ProcessTimeRangeMapper

java.lang.Object

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

org.apache.hadoop.hbase.mapreduce.TableMapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.io.MapWritable>

org.apache.hadoop.hbase.mapreduce.TestTimeRangeMapRed.ProcessTimeRangeMapper

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable

Enclosing class:

TestTimeRangeMapRed

private static class TestTimeRangeMapRed.ProcessTimeRangeMapper
extends org.apache.hadoop.hbase.mapreduce.TableMapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.io.MapWritable>
implements org.apache.hadoop.conf.Configurable

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 org.apache.hadoop.conf.Configuration	conf
private org.apache.hadoop.hbase.client.Table	table

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ProcessTimeRangeMapper()

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.conf.Configuration	getConf()
void	map(org.apache.hadoop.hbase.io.ImmutableBytesWritable key, org.apache.hadoop.hbase.client.Result result, org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Result,org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.io.MapWritable>.org.apache.hadoop.mapreduce.Mapper.Context context)
void	setConf(org.apache.hadoop.conf.Configuration configuration)

Methods inherited from class org.apache.hadoop.mapreduce.Mapper

cleanup, run, setup

Methods inherited from class java.lang.Object

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

Field Details

conf

private org.apache.hadoop.conf.Configuration conf

table

private org.apache.hadoop.hbase.client.Table table

Constructor Details

ProcessTimeRangeMapper

private ProcessTimeRangeMapper()

Method Details

map

public void map(org.apache.hadoop.hbase.io.ImmutableBytesWritable key,
 org.apache.hadoop.hbase.client.Result result,
 org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Result,org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.io.MapWritable>.org.apache.hadoop.mapreduce.Mapper.Context context)
         throws IOException

Overrides:

map in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Result,org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.io.MapWritable>

Throws:

IOException

getConf

public org.apache.hadoop.conf.Configuration getConf()

Specified by:

getConf in interface org.apache.hadoop.conf.Configurable

setConf

public void setConf(org.apache.hadoop.conf.Configuration configuration)

Specified by:

setConf in interface org.apache.hadoop.conf.Configurable