code: private void processPlainFileSources(URI inputURI) throws IOException {
      LOG.info("Scheme specific part is: " + inputURI.getSchemeSpecificPart());
  
      File inputFile = new File(inputURI.getSchemeSpecificPart());
  
      // Check if input is a directory
      if (!inputFile.isDirectory()) {
        throw new IOException("Input is not a regular directory: " + input);
      }
  
      File[] files = inputFile.listFiles();
      int processedCount = 0;
      try {
        for (File f : files) {
          // Process only files, not (sub)directories.
          if (f.isFile()) {
            processPlainFile(hdfs, f, outputPath, skipExisting);
            processedCount++;
            // Print something each 100 files to show progress.
            if ((processedCount % 1000) == 0) {
              LOG.info("Processed " + processedCount + " files.");
            }
          }
        }
      } finally {
        LOG.info("Processed " + processedCount + " files.");
      }
    }
docs: Input is a regular directory (non-hdfs). Process files accordingly.
  
  @param inputURI
  @throws IOException