Package org.apache.hadoop.hbase.backup.mapreduce

Class MapReduceHFileSplitterJob.HFileCellMapper

java.lang.Object

org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,Cell,org.apache.hadoop.io.WritableComparable<?>,Cell>

org.apache.hadoop.hbase.backup.mapreduce.MapReduceHFileSplitterJob.HFileCellMapper

Enclosing class:

MapReduceHFileSplitterJob

static class MapReduceHFileSplitterJob.HFileCellMapper
extends org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,Cell,org.apache.hadoop.io.WritableComparable<?>,Cell>

A mapper that just writes out cells. This one can be used together with CellSortReducer

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 boolean	diskBasedSortingEnabled

Constructor Summary

Constructors

Constructor	Description
HFileCellMapper()

Method Summary

Modifier and Type	Method	Description
void	map(org.apache.hadoop.io.NullWritable key, Cell value, org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,Cell,org.apache.hadoop.io.WritableComparable<?>,Cell>.org.apache.hadoop.mapreduce.Mapper.Context context)
void	setup(org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,Cell,org.apache.hadoop.io.WritableComparable<?>,Cell>.org.apache.hadoop.mapreduce.Mapper.Context context)
private org.apache.hadoop.io.WritableComparable<?>	wrap(ExtendedCell cell)

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

diskBasedSortingEnabled

private boolean diskBasedSortingEnabled

Constructor Details

HFileCellMapper

HFileCellMapper()

Method Details

map

public void map(org.apache.hadoop.io.NullWritable key,
 Cell value,
 org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,Cell,org.apache.hadoop.io.WritableComparable<?>,Cell>.org.apache.hadoop.mapreduce.Mapper.Context context)
         throws IOException,
InterruptedException

Overrides:

map in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,Cell,org.apache.hadoop.io.WritableComparable<?>,Cell>

Throws:

IOException

InterruptedException

setup

public void setup(org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,Cell,org.apache.hadoop.io.WritableComparable<?>,Cell>.org.apache.hadoop.mapreduce.Mapper.Context context)
           throws IOException

Overrides:

setup in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,Cell,org.apache.hadoop.io.WritableComparable<?>,Cell>

Throws:

IOException

wrap

private org.apache.hadoop.io.WritableComparable<?> wrap(ExtendedCell cell)