static

in interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/config/YamlConfigs.java [33:227]

• 194 lines of code
• 24 McCabe index (conditional complexity)

    static {
        ImmutableMap.Builder<String, ValueGetter> mapBuilder = ImmutableMap.builder();
        mapBuilder
                .put(
                        "graph.planner.is.on",
                        (Configs configs) -> configs.get("compiler.planner.is_on"))
                .put("graph.planner.opt", (Configs configs) -> configs.get("compiler.planner.opt"))
                .put(
                        "graph.planner.cbo.glogue.size",
                        (Configs configs) -> configs.get("compiler.planner.cbo.glogue.size"))
                .put(
                        "graph.planner.trim.class.names",
                        (Configs configs) -> configs.get("compiler.planner.trim_class_names"))
                .put(
                        "graph.planner.rules",
                        (Configs configs) -> {
                            String rules = configs.get("compiler.planner.rules");
                            if (rules != null) {
                                rules = rules.replace("[", "").replace("]", "");
                            }
                            return rules;
                        })
                .put(
                        "graph.schema",
                        (Configs configs) -> {
                            // if System.properties contains graph.schema, use it
                            String schema = System.getProperty("graph.schema");
                            if (schema != null) {
                                return schema;
                            }
                            return configs.get("compiler.meta.reader.schema.uri");
                        })
                .put(
                        "graph.statistics",
                        (Configs configs) -> {
                            String statistics = System.getProperty("graph.statistics");
                            if (statistics != null) {
                                return statistics;
                            }
                            return configs.get("compiler.meta.reader.statistics.uri");
                        })
                .put(
                        "graph.functions",
                        (Configs configs) -> {
                            String functions = System.getProperty("graph.functions");
                            if (functions != null) {
                                return functions;
                            }
                            return configs.get("compiler.meta.reader.functions.uri");
                        })
                .put(
                        "graph.meta.schema.fetch.interval.ms",
                        (Configs configs) -> configs.get("compiler.meta.reader.schema.interval"))
                .put(
                        "graph.meta.statistics.fetch.interval.ms",
                        (Configs configs) ->
                                configs.get("compiler.meta.reader.statistics.interval"))
                .put(
                        "graph.meta.fetch.timeout.ms",
                        (Configs configs) -> configs.get("compiler.meta.reader.timeout"))
                .put(
                        "graph.store",
                        (Configs configs) -> {
                            if (configs.get("compute_engine.store.type") != null) {
                                return configs.get("compute_engine.store.type");
                            } else {
                                return "cpp-mcsr";
                            }
                        })
                .put(
                        "graph.physical.opt",
                        (Configs configs) -> {
                            if (configs.get("compiler.physical.opt.config") != null) {
                                return configs.get("compiler.physical.opt.config");
                            } else {
                                return "ffi"; // default proto
                            }
                        })
                .put(
                        "pegasus.worker.num",
                        (Configs configs) -> {
                            String type = configs.get("compute_engine.type");
                            if (type == null || !type.equals("pegasus")) {
                                return null;
                            } else {
                                return configs.get("compute_engine.thread_num_per_worker");
                            }
                        })
                .put(
                        "pegasus.batch.size",
                        (Configs configs) -> {
                            String type = configs.get("compute_engine.type");
                            if (type == null || !type.equals("pegasus")) {
                                return null;
                            } else {
                                return configs.get("compute_engine.batch_size");
                            }
                        })
                .put(
                        "pegasus.output.capacity",
                        (Configs configs) -> {
                            String type = configs.get("compute_engine.type");
                            if (type == null || !type.equals("pegasus")) {
                                return null;
                            } else {
                                return configs.get("compute_engine.output_capacity");
                            }
                        })
                .put(
                        "pegasus.hosts",
                        (Configs configs) -> {
                            String type = configs.get("compute_engine.type");
                            if (type == null || !type.equals("pegasus")) {
                                return null;
                            } else {
                                String hosts = configs.get("compute_engine.workers");
                                if (hosts != null) {
                                    return hosts.replace("[", "").replace("]", "");
                                }
                                return hosts;
                            }
                        })
                .put(
                        "hiactor.hosts",
                        (Configs configs) -> {
                            String type = configs.get("compute_engine.type");
                            if (type == null || !type.equals("hiactor")) {
                                return null;
                            } else {
                                String port = configs.get("http_service.query_port");
                                String address = configs.get("http_service.default_listen_address");
                                if (port != null && address != null) {
                                    String hosts = address + ":" + port;
                                    return hosts.replace("[", "").replace("]", "");
                                }
                                return null;
                            }
                        })
                .put(
                        "interactive.admin.endpoint",
                        (Configs configs) -> {
                            String host = configs.get("http_service.default_listen_address");
                            String port = configs.get("http_service.admin_port");
                            if (host != null) {
                                if (port != null) {
                                    return "http://" + host + ":" + port;
                                }
                            }
                            return null;
                        })
                .put(
                        "interactive.query.endpoint",
                        (Configs configs) -> {
                            String host = configs.get("http_service.default_listen_address");
                            String port = configs.get("http_service.query_port");
                            if (host != null) {
                                if (port != null) {
                                    return "http://" + host + ":" + port;
                                }
                            }
                            return null;
                        })
                .put(
                        "neo4j.bolt.server.disabled",
                        (Configs configs) ->
                                configs.get("compiler.endpoint.bolt_connector.disabled"))
                .put(
                        "neo4j.bolt.server.port",
                        (Configs configs) -> configs.get("compiler.endpoint.bolt_connector.port"))
                .put(
                        "gremlin.server.disabled",
                        (Configs configs) ->
                                configs.get("compiler.endpoint.gremlin_connector.disabled"))
                .put(
                        "gremlin.server.port",
                        (Configs configs) ->
                                configs.get("compiler.endpoint.gremlin_connector.port"))
                .put(
                        "query.execution.timeout.ms",
                        (Configs configs) -> configs.get("compiler.query_timeout"))
                .put(
                        "query.execution.max.iterations",
                        (Configs configs) -> configs.get("compiler.query_max_iterations"))
                .put("engine.type", (Configs configs) -> configs.get("compute_engine.type"))
                .put(
                        "calcite.default.charset",
                        (Configs configs) -> configs.get("compiler.calcite_default_charset"))
                .put(
                        "gremlin.script.language.name",
                        (Configs configs) -> configs.get("compiler.gremlin_script_language_name"))
                .put(
                        "graph.type.inference.enabled",
                        (Configs configs) -> configs.get("compiler.type_inference_enabled"));
        valueGetterMap = mapBuilder.build();
    }