class DynamicInputFormat extends InputFormat<K, V> {

  @Override
  public List<InputSplit> getSplits(JobContext jobContext) throws IOException, InterruptedException {
    LOG.info("DynamicInputFormat: Getting splits for job: {}", jobContext.getJobID());
    return createSplits(jobContext, splitCopyListingIntoChunksWithShuffle(jobContext));
  }

}