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) |
cleanupprivate 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.LoadMapperIOExceptionprotected 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.LoadMapperIOExceptionInterruptedExceptionprivate org.apache.hadoop.mapreduce.Counter getCounter(int idx)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.