org.apache.hadoop.hbase.test

Class IntegrationTestBigLinkedListWithVisibility.VisibilityDeleteImport

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.hbase.client.Mutation>

org.apache.hadoop.hbase.mapreduce.Import.Importer

org.apache.hadoop.hbase.test.IntegrationTestBigLinkedListWithVisibility.VisibilityDeleteImport

Enclosing class:

IntegrationTestBigLinkedListWithVisibility

static class IntegrationTestBigLinkedListWithVisibility.VisibilityDeleteImport
extends org.apache.hadoop.hbase.mapreduce.Import.Importer

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 int	index
private String	labels
private String[]	split

Constructor Summary

Constructors

Constructor and Description
VisibilityDeleteImport()

Method Summary

Modifier and Type	Method and Description
protected void	processKV(org.apache.hadoop.hbase.io.ImmutableBytesWritable key, org.apache.hadoop.hbase.client.Result result, org.apache.hadoop.mapreduce.Mapper.Context context, org.apache.hadoop.hbase.client.Put put, org.apache.hadoop.hbase.client.Delete delete)
void	setup(org.apache.hadoop.mapreduce.Mapper.Context context)

Methods inherited from class org.apache.hadoop.hbase.mapreduce.Import.Importer

addPutToKv, map

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 Detail

index

private int index

labels

private String labels

split

private String[] split

Constructor Detail

VisibilityDeleteImport

VisibilityDeleteImport()

Method Detail

setup

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

Overrides:

setup in class org.apache.hadoop.hbase.mapreduce.Import.Importer

processKV

protected void processKV(org.apache.hadoop.hbase.io.ImmutableBytesWritable key,
                         org.apache.hadoop.hbase.client.Result result,
                         org.apache.hadoop.mapreduce.Mapper.Context context,
                         org.apache.hadoop.hbase.client.Put put,
                         org.apache.hadoop.hbase.client.Delete delete)
                  throws IOException,
                         InterruptedException

Overrides:

processKV in class org.apache.hadoop.hbase.mapreduce.Import.Importer

Throws:

IOException

InterruptedException