class ForwardingBigQueryFileOutputCommitter extends OutputCommitter {

  protected List<String> getOutputFileURIs() throws IOException {
    // Enumerate over all files in the output path.
    FileStatus[] outputFiles = outputFileSystem.listStatus(outputPath);
    ArrayList<String> sourceUris = new ArrayList<String>(outputFiles.length);

    for (int i = 0; i < outputFiles.length; i++) {
      FileStatus fileStatus = outputFiles[i];

      // Skip the success file and directories as they're not relevant to BigQuery.
      if (!fileStatus.isDir()
          && !fileStatus.getPath().getName().equals(FileOutputCommitter.SUCCEEDED_FILE_NAME)) {
        sourceUris.add(fileStatus.getPath().toString());
      }
    }

    return sourceUris;
  }

  public  ForwardingBigQueryFileOutputCommitter(TaskAttemptContext context, OutputCommitter delegate);

}