private static boolean addHBaseConfIfFound()

in flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/util/HBaseConfigurationUtil.java [91:116]

26 lines of code
4 McCabe index (conditional complexity)


    private static boolean addHBaseConfIfFound(
            Configuration configuration, String possibleHBaseConfPath) {
        boolean foundHBaseConfiguration = false;
        if (new File(possibleHBaseConfPath).exists()) {
            if (new File(possibleHBaseConfPath + "/hbase-default.xml").exists()) {
                configuration.addResource(
                        new org.apache.hadoop.fs.Path(
                                possibleHBaseConfPath + "/hbase-default.xml"));
                LOG.debug(
                        "Adding "
                                + possibleHBaseConfPath
                                + "/hbase-default.xml to hbase configuration");
                foundHBaseConfiguration = true;
            }
            if (new File(possibleHBaseConfPath + "/hbase-site.xml").exists()) {
                configuration.addResource(
                        new org.apache.hadoop.fs.Path(possibleHBaseConfPath + "/hbase-site.xml"));
                LOG.debug(
                        "Adding "
                                + possibleHBaseConfPath
                                + "/hbase-site.xml to hbase configuration");
                foundHBaseConfiguration = true;
            }
        }
        return foundHBaseConfiguration;
    }