com.google.cloud.bigtable.mapreduce.hbasesnapshots

Class ImportHBaseSnapshotJob.SnapshotMapper

java.lang.Object

org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,KEYOUT,VALUEOUT>

org.apache.hadoop.hbase.mapreduce.TableMapper<ImmutableBytesWritable,Put>

com.google.cloud.bigtable.mapreduce.hbasesnapshots.ImportHBaseSnapshotJob.SnapshotMapper

Enclosing class:

ImportHBaseSnapshotJob

protected static class ImportHBaseSnapshotJob.SnapshotMapper
extends TableMapper<ImmutableBytesWritable,Put>

MAPPER

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 and Description
protected static int	MAX_CELLS

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SnapshotMapper()

Method Summary

Modifier and Type	Method and Description
protected void	cleanup(org.apache.hadoop.mapreduce.Mapper.Context ctx)
protected void	map(ImmutableBytesWritable key, Result result, org.apache.hadoop.mapreduce.Mapper.Context ctx)
protected void	setup(org.apache.hadoop.mapreduce.Mapper.Context ctx)

Methods inherited from class org.apache.hadoop.mapreduce.Mapper

run

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MAX_CELLS

protected static final int MAX_CELLS

See Also:

Constant Field Values

Constructor Detail

SnapshotMapper

protected SnapshotMapper()

Method Detail

setup

protected void setup(org.apache.hadoop.mapreduce.Mapper.Context ctx)

Overrides:

setup in class org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,Put>

map

protected void map(ImmutableBytesWritable key,
                   Result result,
                   org.apache.hadoop.mapreduce.Mapper.Context ctx)
            throws IOException,
                   InterruptedException

Overrides:

map in class org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,Put>

Throws:

IOException

InterruptedException

cleanup

protected void cleanup(org.apache.hadoop.mapreduce.Mapper.Context ctx)

Overrides:

cleanup in class org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,Put>