public static ShellResult configure()

in bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/flink/FlinkSetup.java [36:92]
48 lines of code
1 McCabe index (conditional complexity)

    public static ShellResult configure(Params params) {
        log.info("Configuring Flink");
        FlinkParams flinkParams = (FlinkParams) params;
        String flinkUser = params.user();
        String flinkGroup = params.group();
        String confDir = flinkParams.confDir();

        LinuxFileUtils.createDirectories(
                flinkParams.getFlinkLogDir(), flinkUser, flinkGroup, Constants.PERMISSION_755, true);
        LinuxFileUtils.createDirectories(
                flinkParams.getFlinkPidDir(), flinkUser, flinkGroup, Constants.PERMISSION_755, true);

        LinuxFileUtils.toFileByTemplate(
                flinkParams.getFlinkLog4jPropertiesContent(),
                MessageFormat.format("{0}/log4j.properties", confDir),
                flinkUser,
                flinkGroup,
                Constants.PERMISSION_644,
                flinkParams.getGlobalParamsMap());

        LinuxFileUtils.toFileByTemplate(
                flinkParams.getFlinkLog4jCLiPropertiesContent(),
                MessageFormat.format("{0}/log4j-cli.properties", confDir),
                flinkUser,
                flinkGroup,
                Constants.PERMISSION_644,
                flinkParams.getGlobalParamsMap());

        LinuxFileUtils.toFileByTemplate(
                flinkParams.getFlinkLog4jConsolePropertiesContent(),
                MessageFormat.format("{0}/log4j-console.properties", confDir),
                flinkUser,
                flinkGroup,
                Constants.PERMISSION_644,
                flinkParams.getGlobalParamsMap());

        LinuxFileUtils.toFileByTemplate(
                flinkParams.getFlinkLog4jSessionPropertiesContent(),
                MessageFormat.format("{0}/log4j-session.properties", confDir),
                flinkUser,
                flinkGroup,
                Constants.PERMISSION_644,
                flinkParams.getGlobalParamsMap());

        LinuxFileUtils.toFileByTemplate(
                flinkParams.getFlinkConfContent(),
                MessageFormat.format("{0}/flink-conf.yaml", confDir),
                flinkUser,
                flinkGroup,
                Constants.PERMISSION_644,
                flinkParams.getGlobalParamsMap());

        //        HdfsUtil.createDirectory(flinkUser, "/completed-jobs");

        log.info("Successfully configured Flink");
        return ShellResult.success();
    }