protected Configuration createConfiguration()

in src/main/java/org/apache/flink/benchmark/BlockingPartitionRemoteChannelBenchmark.java [78:95]

17 lines of code
2 McCabe index (conditional complexity)


        protected Configuration createConfiguration(boolean isSortShuffle) {
            Configuration configuration = super.createConfiguration();

            if (isSortShuffle) {
                configuration.setInteger(
                        NettyShuffleEnvironmentOptions.NETWORK_SORT_SHUFFLE_MIN_PARALLELISM, 1);
            } else {
                configuration.setInteger(
                        NettyShuffleEnvironmentOptions.NETWORK_SORT_SHUFFLE_MIN_PARALLELISM,
                        Integer.MAX_VALUE);
            }
            configuration.setString(
                    NettyShuffleEnvironmentOptions.NETWORK_BLOCKING_SHUFFLE_TYPE, "file");
            configuration.setString(
                    CoreOptions.TMP_DIRS,
                    FileUtils.getCurrentWorkingDirectory().toAbsolutePath().toString());
            return configuration;
        }