org.apache.hadoop.hbase.mapreduce

Class ImportTsv

java.lang.Object

Configured

org.apache.hadoop.hbase.mapreduce.ImportTsv

@InterfaceAudience.Public
 @InterfaceStability.Stable
public class ImportTsv
extends Configured

Tool to import data from a TSV file. This tool is rather simplistic - it doesn't do any quoting or escaping, but is useful for many data loads.

See Also:

usage(String)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ImportTsv.TsvParser

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	ATTRIBUTE_SEPERATOR_CONF_KEY
static java.lang.String	BULK_OUTPUT_CONF_KEY
static java.lang.String	COLUMNS_CONF_KEY
static java.lang.String	CREATE_TABLE_CONF_KEY
static java.lang.String	CREDENTIALS_LOCATION
static java.lang.String	JOB_NAME_CONF_KEY
protected static Log	LOG
static java.lang.String	MAPPER_CONF_KEY
static java.lang.String	NO_STRICT_COL_FAMILY
static java.lang.String	SEPARATOR_CONF_KEY
static java.lang.String	SKIP_LINES_CONF_KEY
static java.lang.String	TIMESTAMP_CONF_KEY

Constructor Summary

Constructors

Constructor and Description
ImportTsv()

Method Summary

Modifier and Type	Method and Description
static Job	createSubmittableJob(Configuration conf, java.lang.String[] args) Sets up the actual job.
static void	main(java.lang.String[] args)
int	run(java.lang.String[] args)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final Log LOG

MAPPER_CONF_KEY

public static final java.lang.String MAPPER_CONF_KEY

See Also:

Constant Field Values

BULK_OUTPUT_CONF_KEY

public static final java.lang.String BULK_OUTPUT_CONF_KEY

See Also:

Constant Field Values

TIMESTAMP_CONF_KEY

public static final java.lang.String TIMESTAMP_CONF_KEY

See Also:

Constant Field Values

JOB_NAME_CONF_KEY

public static final java.lang.String JOB_NAME_CONF_KEY

See Also:

Constant Field Values

SKIP_LINES_CONF_KEY

public static final java.lang.String SKIP_LINES_CONF_KEY

See Also:

Constant Field Values

COLUMNS_CONF_KEY

public static final java.lang.String COLUMNS_CONF_KEY

See Also:

Constant Field Values

SEPARATOR_CONF_KEY

public static final java.lang.String SEPARATOR_CONF_KEY

See Also:

Constant Field Values

ATTRIBUTE_SEPERATOR_CONF_KEY

public static final java.lang.String ATTRIBUTE_SEPERATOR_CONF_KEY

See Also:

Constant Field Values

CREDENTIALS_LOCATION

public static final java.lang.String CREDENTIALS_LOCATION

See Also:

Constant Field Values

CREATE_TABLE_CONF_KEY

public static final java.lang.String CREATE_TABLE_CONF_KEY

See Also:

Constant Field Values

NO_STRICT_COL_FAMILY

public static final java.lang.String NO_STRICT_COL_FAMILY

See Also:

Constant Field Values

Constructor Detail

ImportTsv

public ImportTsv()

Method Detail

createSubmittableJob

public static Job createSubmittableJob(Configuration conf,
                                       java.lang.String[] args)
                                throws java.io.IOException,
                                       java.lang.ClassNotFoundException

Sets up the actual job.

Parameters:

conf - The current configuration.

args - The command line parameters.

Returns:

The newly created job.

Throws:

java.io.IOException - When setting up the job fails.

java.lang.ClassNotFoundException

run

public int run(java.lang.String[] args)
        throws java.lang.Exception

Throws:

java.lang.Exception

main

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

Throws:

java.lang.Exception