class HdfsFileFragmenter extends HdfsDataFragmenter {

    @Override
    public List<Fragment> getFragments() throws Exception {
        String fileName = hcfsType.getDataUri(jobConf, context);
        Path path = new Path(fileName);

        PxfInputFormat pxfInputFormat = new PxfInputFormat();
        PxfInputFormat.setInputPaths(jobConf, path);

        FileStatus[] fileStatusArray;

        try {
            fileStatusArray = pxfInputFormat.listStatus(jobConf);
        } catch (InvalidInputException e) {
            if (StringUtils.equalsIgnoreCase("true", context.getOption(IGNORE_MISSING_PATH_OPTION))) {
                LOG.debug("Ignoring InvalidInputException", e);
                return fragments;
            }
            throw e;
        }

        fragments = Arrays.stream(fileStatusArray)
                .map(fileStatus -> new Fragment(fileStatus.getPath().toUri().toString()))
                .collect(Collectors.toList());
        LOG.debug("Total number of fragments = {}", fragments.size());

        return fragments;
    }

    public  HdfsFileFragmenter();
      HdfsFileFragmenter(ConfigurationFactory configurationFactory);

}