class TSFHiveInputFormat extends FileInputFormat<NullWritable, MapWritable> {

  @Override
  public InputSplit[] getSplits(JobConf job, int numSplits) throws IOException {
    job.setBoolean(INPUT_DIR_RECURSIVE, true);
    return TSFInputFormat.getTSFInputSplit(job, Arrays.asList(super.listStatus(job)), logger)
        .toArray(new InputSplit[0]);
  }

}