public static File createStateDataDir()

in src/main/java/org/apache/flink/state/benchmark/StateBenchmarkBase.java [73:84]

• 12 lines of code
• 3 McCabe index (conditional complexity)

    public static File createStateDataDir() throws IOException {
        Configuration benchMarkConfig = ConfigUtil.loadBenchMarkConf();
        String stateDataDirPath = benchMarkConfig.get(StateBenchmarkOptions.STATE_DATA_DIR);
        File dataDir = null;
        if (stateDataDirPath != null) {
            dataDir = new File(stateDataDirPath);
            if (!dataDir.exists()) {
                Files.createDirectories(Paths.get(stateDataDirPath));
            }
        }
        return dataDir;
    }