org.apache.hadoop.hbase.test

Class IntegrationTestLoadAndVerify.WALSearcher.WALMapperSearcher

java.lang.Object

org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.hbase.wal.WALKey,org.apache.hadoop.hbase.wal.WALEdit,org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Mutation>

org.apache.hadoop.hbase.test.IntegrationTestLoadAndVerify.WALSearcher.WALMapperSearcher

Enclosing class:

IntegrationTestLoadAndVerify.WALSearcher

public static class IntegrationTestLoadAndVerify.WALSearcher.WALMapperSearcher
extends org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.hbase.wal.WALKey,org.apache.hadoop.hbase.wal.WALEdit,org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Mutation>

The actual searcher mapper.

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 and Description
private SortedSet<byte[]>	keysToFind
private AtomicInteger	rows

Constructor Summary

Constructors

Constructor and Description
WALMapperSearcher()

Method Summary

Modifier and Type	Method and Description
protected boolean	filter(org.apache.hadoop.mapreduce.Mapper.Context context, org.apache.hadoop.hbase.Cell cell)
void	setup(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 Detail

keysToFind

private SortedSet<byte[]> keysToFind

rows

private AtomicInteger rows

Constructor Detail

WALMapperSearcher

public WALMapperSearcher()

Method Detail

setup

public void setup(org.apache.hadoop.mapreduce.Mapper.Context context)
           throws IOException

Throws:

IOException

filter

protected boolean filter(org.apache.hadoop.mapreduce.Mapper.Context context,
                         org.apache.hadoop.hbase.Cell cell)