Field Detail

• LOG

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

• COLUMN_LIST

  public static final String COLUMN_LIST

  space delimited list of columns

  See Also:

  Constant Field Values

Constructor Detail

• TableInputFormat

  public TableInputFormat()

Method Detail

• configure

  public void configure(org.apache.hadoop.mapred.JobConf job)

  Specified by:

  configure in interface org.apache.hadoop.mapred.JobConfigurable

• initialize

  protected void initialize(org.apache.hadoop.mapred.JobConf job)
                     throws IOException

  Description copied from class: TableInputFormatBase
  Handle subclass specific set up. Each of the entry points used by the MapReduce framework, TableInputFormatBase.getRecordReader(InputSplit, JobConf, Reporter) and TableInputFormatBase.getSplits(JobConf, int), will call TableInputFormatBase.initialize(JobConf) as a convenient centralized location to handle retrieving the necessary configuration information and calling TableInputFormatBase.initializeTable(Connection, TableName). Subclasses should implement their initialize call such that it is safe to call multiple times. The current TableInputFormatBase implementation relies on a non-null table reference to decide if an initialize call is needed, but this behavior may change in the future. In particular, it is critical that initializeTable not be called multiple times since this will leak Connection instances.

  Overrides:

  initialize in class TableInputFormatBase

  Throws:

  IOException

• validateInput

  public void validateInput(org.apache.hadoop.mapred.JobConf job)
                     throws IOException

  Throws:

  IOException