Field Detail

• LOG

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

• NAME

  static final String NAME

  See Also:

  Constant Field Values

• 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

• SKIP_LINES_CONF_KEY

  public static final String SKIP_LINES_CONF_KEY

  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

• DEFAULT_SEPARATOR

  static final String DEFAULT_SEPARATOR

  See Also:

  Constant Field Values

• DEFAULT_ATTRIBUTES_SEPERATOR

  static final String DEFAULT_ATTRIBUTES_SEPERATOR

  See Also:

  Constant Field Values

• DEFAULT_MULTIPLE_ATTRIBUTES_SEPERATOR

  static final String DEFAULT_MULTIPLE_ATTRIBUTES_SEPERATOR

  See Also:

  Constant Field Values

• DEFAULT_MAPPER

  static final Class DEFAULT_MAPPER

• 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

• DRY_RUN_TABLE_CREATED

  private static boolean DRY_RUN_TABLE_CREATED

  If table didn't exist and was created in dry-run mode, this flag is flipped to delete it when MR ends.

Constructor Detail

• ImportTsv

  public ImportTsv()

Method Detail

• createSubmittableJob

  public 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

• createTable

  private static void createTable(Admin admin,
                 TableName tableName,
                 String[] columns)
                           throws IOException

  Throws:

  IOException

• getColumnFamilies

  private static Set<String> getColumnFamilies(String[] columns)

• usage

  private static void usage(String errorMsg)

• 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