Package org.apache.hadoop.hbase.mapreduce

Class WALPlayer.WALMapper

java.lang.Object

org.apache.hadoop.mapreduce.Mapper<WALKey,WALEdit,ImmutableBytesWritable,Mutation>

org.apache.hadoop.hbase.mapreduce.WALPlayer.WALMapper

Enclosing class:

WALPlayer

protected static class WALPlayer.WALMapper
extends org.apache.hadoop.mapreduce.Mapper<WALKey,WALEdit,ImmutableBytesWritable,Mutation>

A mapper that writes out Mutation to be directly applied to a running HBase instance.

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<TableName,TableName>	tables

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	WALMapper()

Method Summary

Modifier and Type	Method	Description
protected void	cleanup(org.apache.hadoop.mapreduce.Mapper<WALKey,WALEdit,ImmutableBytesWritable,Mutation>.org.apache.hadoop.mapreduce.Mapper.Context context)
protected boolean	filter(org.apache.hadoop.mapreduce.Mapper<WALKey,WALEdit,ImmutableBytesWritable,Mutation>.org.apache.hadoop.mapreduce.Mapper.Context context, Cell cell)
void	map(WALKey key, WALEdit value, org.apache.hadoop.mapreduce.Mapper<WALKey,WALEdit,ImmutableBytesWritable,Mutation>.org.apache.hadoop.mapreduce.Mapper.Context context)
void	setup(org.apache.hadoop.mapreduce.Mapper<WALKey,WALEdit,ImmutableBytesWritable,Mutation>.org.apache.hadoop.mapreduce.Mapper.Context context)

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

run

Methods inherited from class java.lang.Object

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

Field Details

tables

private Map<TableName,TableName> tables

Constructor Details

WALMapper

protected WALMapper()

Method Details

map

public void map(WALKey key,
 WALEdit value,
 org.apache.hadoop.mapreduce.Mapper<WALKey,WALEdit,ImmutableBytesWritable,Mutation>.org.apache.hadoop.mapreduce.Mapper.Context context)
         throws IOException

Overrides:

map in class org.apache.hadoop.mapreduce.Mapper<WALKey,WALEdit,ImmutableBytesWritable,Mutation>

Throws:

IOException

filter

protected boolean filter(org.apache.hadoop.mapreduce.Mapper<WALKey,WALEdit,ImmutableBytesWritable,Mutation>.org.apache.hadoop.mapreduce.Mapper.Context context,
 Cell cell)

cleanup

protected void cleanup(org.apache.hadoop.mapreduce.Mapper<WALKey,WALEdit,ImmutableBytesWritable,Mutation>.org.apache.hadoop.mapreduce.Mapper.Context context)
                throws IOException,
InterruptedException

Overrides:

cleanup in class org.apache.hadoop.mapreduce.Mapper<WALKey,WALEdit,ImmutableBytesWritable,Mutation>

Throws:

IOException

InterruptedException

setup

public void setup(org.apache.hadoop.mapreduce.Mapper<WALKey,WALEdit,ImmutableBytesWritable,Mutation>.org.apache.hadoop.mapreduce.Mapper.Context context)
           throws IOException

Overrides:

setup in class org.apache.hadoop.mapreduce.Mapper<WALKey,WALEdit,ImmutableBytesWritable,Mutation>

Throws:

IOException