@Test
    public void shouldSupportDirectoryFileDistinction() throws Exception {
        // Make sure Spark is shut down before deleting its files and directories,
        // which are locked under Windows and fail the tests. See FileSystemStorageCheck
        graph.configuration().setProperty(Constants.GREMLIN_SPARK_PERSIST_CONTEXT, false);

        final Storage storage = FileSystemStorage.open(ConfUtil.makeHadoopConfiguration(graph.configuration()));
        final String directory1 = TestHelper.makeTestDataDirectory(FileSystemStorageCheck.class, "directory1");
        final String directory2 = TestHelper.makeTestDataDirectory(FileSystemStorageCheck.class, "directory2");
        for (int i = 0; i < 10; i++) {
            new File(directory1, "file1-" + i + ".txt.bz").createNewFile();
        }
        for (int i = 0; i < 5; i++) {
            new File(directory2, "file2-" + i + ".txt.bz").createNewFile();
        }
        super.checkFileDirectoryDistinction(storage, directory1, directory2);
        deleteDirectory(directory1);
        deleteDirectory(directory2);
    }
@author Marko A. Rodriguez (http://markorodriguez.com)
spark-gremlin/src/test/java/org/apache/tinkerpop/gremlin/hadoop/structure/io/FileSystemStorageCheck.java