com.google.cloud.bigtable.mapreduce.hbasesnapshots

Class ImportHBaseSnapshotJob

java.lang.Object

org.apache.hadoop.conf.Configured

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

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool

public class ImportHBaseSnapshotJob
extends org.apache.hadoop.conf.Configured
implements org.apache.hadoop.util.Tool

A Mapreduce job to import an HBase snapshot to Bigtable.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	ImportHBaseSnapshotJob.ScanCounter
protected static class	ImportHBaseSnapshotJob.SnapshotMapper MAPPER

Constructor Summary

Constructors

Constructor and Description
ImportHBaseSnapshotJob()

Method Summary

Modifier and Type	Method and Description
protected static org.apache.hadoop.mapreduce.Job	createSubmittableJob(org.apache.hadoop.conf.Configuration conf) Sets up the actual job.
static int	innerMain(org.apache.hadoop.conf.Configuration conf, String[] args) Call this method to avoid the main(String[]) System.exit.
static void	main(String[] args)
int	run(String[] args) Job runner
protected static int	setConfFromArgs(org.apache.hadoop.conf.Configuration conf, String[] args)

Methods inherited from class org.apache.hadoop.conf.Configured

getConf, setConf

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.conf.Configurable

getConf, setConf

Constructor Detail

ImportHBaseSnapshotJob

public ImportHBaseSnapshotJob()

Method Detail

run

public int run(String[] args)
        throws Exception

Job runner

Specified by:

run in interface org.apache.hadoop.util.Tool

Parameters:

args - command line input

Returns:

job success flag

Throws:

Exception - terminal for application failure

setConfFromArgs

protected static int setConfFromArgs(org.apache.hadoop.conf.Configuration conf,
                                     String[] args)

createSubmittableJob

protected static org.apache.hadoop.mapreduce.Job createSubmittableJob(org.apache.hadoop.conf.Configuration conf)
                                                               throws IOException

Sets up the actual job.

Parameters:

conf - The current configuration.

Returns:

The newly created job.

Throws:

IOException - When setting up the job fails.

innerMain

public static int innerMain(org.apache.hadoop.conf.Configuration conf,
                            String[] args)
                     throws Exception

Call this method to avoid the main(String[]) System.exit.

Parameters:

args -

Returns:

exitCode

Throws:

Exception

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception