in computer-k8s/src/main/java/org/apache/hugegraph/computer/k8s/driver/KubernetesDriver.java [458:476]
private Map<String, String> computerConf(Map<String, String> defaultConf,
Map<String, String> params) {
Map<String, String> computerConf = new HashMap<>(defaultConf);
Map<String, TypedOption<?, ?>> allOptions = ComputerOptions.instance().options();
params.forEach((k, v) -> {
if (StringUtils.isNotBlank(k) && StringUtils.isNotBlank(v)) {
if (!k.startsWith(Constants.K8S_SPEC_PREFIX) &&
!COMPUTER_PROHIBIT_USER_OPTIONS.contains(k)) {
ConfigOption<?> typedOption = (ConfigOption<?>) allOptions.get(k);
if (typedOption != null) {
// check value
typedOption.parseConvert(v);
}
computerConf.put(k, v);
}
}
});
return computerConf;
}