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

Constructor Summary

Constructors

Constructor	Description
VisibilityDeleteImport()

Method Summary

Modifier and Type	Method	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 Details

index

private int index

labels

private String labels

split

private String[] split

Constructor Details

VisibilityDeleteImport

VisibilityDeleteImport()

Method Details

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