static Map<String, String> createMapFromFiles(String snapshotFileDir)
  {
    try (Stream<Path> paths = Files.walk(Paths.get(snapshotFileDir)))
    {
      return paths
          .filter(path -> path.toString().endsWith(PDL))
          .map(path -> path.toFile())
          .collect(Collectors.toMap(File::getName, File:: getAbsolutePath, (first, second) -> first));
    }
    catch (IOException e)
    {
      _logger.error ("Error while reading snapshot directory: " + snapshotFileDir);
      System.exit(1);
    }
    return null;
  }
@Test(dataProvider = "fileMapTestData")
  public void testCreateMapFromFiles(String inputDir, Map<String, String> expectedFileMap)
  {
    PegasusSchemaSnapshotCompatibilityChecker checker = new PegasusSchemaSnapshotCompatibilityChecker();
    Map<String,String> actualResult = checker.createMapFromFiles(inputDir);
    Assert.assertEquals(actualResult.size(), expectedFileMap.size());
    actualResult.forEach((fileName, path)-> {
      Assert.assertTrue(expectedFileMap.containsKey(fileName));
      Assert.assertEquals(actualResult.get(fileName), expectedFileMap.get(fileName));
    });
  }