Field Detail

• LOG

  protected static final org.apache.commons.logging.Log LOG

• MAPPER_CONF_KEY

  public static final String MAPPER_CONF_KEY

  See Also:

  Constant Field Values

• BULK_OUTPUT_CONF_KEY

  public static final String BULK_OUTPUT_CONF_KEY

  See Also:

  Constant Field Values

• TIMESTAMP_CONF_KEY

  public static final String TIMESTAMP_CONF_KEY

  See Also:

  Constant Field Values

• JOB_NAME_CONF_KEY

  public static final String JOB_NAME_CONF_KEY

  See Also:

  Constant Field Values

• DRY_RUN_CONF_KEY

  public static final String DRY_RUN_CONF_KEY

  See Also:

  Constant Field Values

• LOG_BAD_LINES_CONF_KEY

  public static final String LOG_BAD_LINES_CONF_KEY

  See Also:

  Constant Field Values

• SKIP_LINES_CONF_KEY

  public static final String SKIP_LINES_CONF_KEY

  See Also:

  Constant Field Values

• SKIP_EMPTY_COLUMNS

  public static final String SKIP_EMPTY_COLUMNS

  See Also:

  Constant Field Values

• COLUMNS_CONF_KEY

  public static final String COLUMNS_CONF_KEY

  See Also:

  Constant Field Values

• SEPARATOR_CONF_KEY

  public static final String SEPARATOR_CONF_KEY

  See Also:

  Constant Field Values

• ATTRIBUTE_SEPERATOR_CONF_KEY

  public static final String ATTRIBUTE_SEPERATOR_CONF_KEY

  See Also:

  Constant Field Values

• CREDENTIALS_LOCATION

  public static final String CREDENTIALS_LOCATION

  See Also:

  Constant Field Values

• CREATE_TABLE_CONF_KEY

  public static final String CREATE_TABLE_CONF_KEY

  See Also:

  Constant Field Values

• NO_STRICT_COL_FAMILY

  public static final String NO_STRICT_COL_FAMILY

  See Also:

  Constant Field Values

Constructor Detail

• ImportTsv

  public ImportTsv()

Method Detail

• createSubmittableJob

  protected static org.apache.hadoop.mapreduce.Job createSubmittableJob(org.apache.hadoop.conf.Configuration conf,
                                                     String[] args)
                                                                 throws IOException,
                                                                        ClassNotFoundException

  Sets up the actual job.

  Parameters:

  conf - The current configuration.

  args - The command line parameters.

  Returns:

  The newly created job.

  Throws:

  IOException - When setting up the job fails.

  ClassNotFoundException

• run

  public int run(String[] args)
          throws Exception

  Specified by:

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

  Throws:

  Exception

• main

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

  Throws:

  Exception