public static class IntegrationTestBigLinkedList.Search.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>
Modifier and Type | Field and Description |
---|---|
private SortedSet<byte[]> |
keysToFind |
private AtomicInteger |
rows |
Constructor and Description |
---|
WALMapperSearcher() |
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) |
private SortedSet<byte[]> keysToFind
private AtomicInteger rows
public WALMapperSearcher()
public void setup(org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException
IOException
protected boolean filter(org.apache.hadoop.mapreduce.Mapper.Context context, org.apache.hadoop.hbase.Cell cell)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.