public static class IntegrationTestWithCellVisibilityLoadAndVerify.LoadWithCellVisibilityMapper extends IntegrationTestLoadAndVerify.LoadMapper
Modifier and Type | Field and Description |
---|---|
private org.apache.hadoop.mapreduce.Counter |
rowsExp1 |
private org.apache.hadoop.mapreduce.Counter |
rowsExp2 |
private org.apache.hadoop.mapreduce.Counter |
rowsExp3 |
private org.apache.hadoop.mapreduce.Counter |
rowsexp4 |
conf, connection, mutator, numBackReferencesPerRow, recordsToWrite, refsWritten, rowsWritten, shortTaskId
Constructor and Description |
---|
LoadWithCellVisibilityMapper() |
Modifier and Type | Method and Description |
---|---|
private org.apache.hadoop.mapreduce.Counter |
getCounter(int idx) |
protected void |
map(org.apache.hadoop.io.NullWritable key,
org.apache.hadoop.io.NullWritable value,
org.apache.hadoop.mapreduce.Mapper.Context context) |
void |
setup(org.apache.hadoop.mapreduce.Mapper.Context context) |
cleanup
private org.apache.hadoop.mapreduce.Counter rowsExp1
private org.apache.hadoop.mapreduce.Counter rowsExp2
private org.apache.hadoop.mapreduce.Counter rowsExp3
private org.apache.hadoop.mapreduce.Counter rowsexp4
public LoadWithCellVisibilityMapper()
public void setup(org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException
setup
in class IntegrationTestLoadAndVerify.LoadMapper
IOException
protected void map(org.apache.hadoop.io.NullWritable key, org.apache.hadoop.io.NullWritable value, org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException, InterruptedException
map
in class IntegrationTestLoadAndVerify.LoadMapper
IOException
InterruptedException
private org.apache.hadoop.mapreduce.Counter getCounter(int idx)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.