@InterfaceAudience.Private public class SweepMapper extends TableMapper<Text,KeyValue>
Constructor and Description |
---|
SweepMapper() |
Modifier and Type | Method and Description |
---|---|
protected void |
cleanup(Context context) |
void |
map(ImmutableBytesWritable r,
Result columns,
Context context) |
protected void |
setup(Context context) |
protected void setup(Context context) throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
protected void cleanup(Context context) throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public void map(ImmutableBytesWritable r, Result columns, Context context) throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException