public class ImportTsv
extends Configured
usage(String)
Modifier and Type | Class and Description |
---|---|
static class |
ImportTsv.TsvParser |
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 |
DRY_RUN_CONF_KEY |
static java.lang.String |
JOB_NAME_CONF_KEY |
protected static Logger |
LOG |
static java.lang.String |
LOG_BAD_LINES_CONF_KEY |
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_EMPTY_COLUMNS |
static java.lang.String |
SKIP_LINES_CONF_KEY |
static java.lang.String |
TIMESTAMP_CONF_KEY |
Constructor and Description |
---|
ImportTsv() |
Modifier and Type | Method and Description |
---|---|
protected 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) |
protected static final Logger LOG
public static final java.lang.String MAPPER_CONF_KEY
public static final java.lang.String BULK_OUTPUT_CONF_KEY
public static final java.lang.String TIMESTAMP_CONF_KEY
public static final java.lang.String JOB_NAME_CONF_KEY
public static final java.lang.String DRY_RUN_CONF_KEY
public static final java.lang.String LOG_BAD_LINES_CONF_KEY
public static final java.lang.String SKIP_LINES_CONF_KEY
public static final java.lang.String SKIP_EMPTY_COLUMNS
public static final java.lang.String COLUMNS_CONF_KEY
public static final java.lang.String SEPARATOR_CONF_KEY
public static final java.lang.String ATTRIBUTE_SEPERATOR_CONF_KEY
public static final java.lang.String CREDENTIALS_LOCATION
public static final java.lang.String CREATE_TABLE_CONF_KEY
public static final java.lang.String NO_STRICT_COL_FAMILY
protected static Job createSubmittableJob(Configuration conf, java.lang.String[] args) throws java.io.IOException, java.lang.ClassNotFoundException
conf
- The current configuration.args
- The command line parameters.java.io.IOException
- When setting up the job fails.java.lang.ClassNotFoundException
public int run(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception
public static void main(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception