public static class SyncTable.SyncMapper extends TableMapper<ImmutableBytesWritable,Mutation>
Modifier and Type | Class and Description |
---|---|
static class |
SyncTable.SyncMapper.Counter |
Constructor and Description |
---|
SyncTable.SyncMapper() |
Modifier and Type | Method and Description |
---|---|
protected void |
cleanup(org.apache.hadoop.mapreduce.Mapper.Context context) |
protected void |
map(ImmutableBytesWritable key,
Result value,
org.apache.hadoop.mapreduce.Mapper.Context context) |
protected void |
setup(org.apache.hadoop.mapreduce.Mapper.Context context) |
protected void setup(org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException
setup
in class org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,Mutation>
IOException
protected void map(ImmutableBytesWritable key, Result value, org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException, InterruptedException
map
in class org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,Mutation>
IOException
InterruptedException
protected void cleanup(org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException, InterruptedException
cleanup
in class org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,Mutation>
IOException
InterruptedException
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.