private static void parseConfigurationOptions()

in playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/entrypoint/LocalEnvironmentEntrypoint.java [66:87]

19 lines of code
4 McCabe index (conditional complexity)


  private static void parseConfigurationOptions(
      MultipleParameterTool parameterTool, Configuration flinkConfiguration) {
    final Collection<String> configurationOptions =
        parameterTool.getMultiParameter(CONFIGURATION_OPTION);

    if (configurationOptions != null) {
      for (String configurationOption : configurationOptions) {
        final String[] splits = configurationOption.split("=");

        if (splits.length != 2) {
          throw new IllegalArgumentException(
              String.format(
                  "The '--%s' value must have the form 'key=value'", CONFIGURATION_OPTION));
        }

        final String key = splits[0];
        final String value = splits[1];
        LOG.info("Setting configuration value: {}={}", key, value);
        flinkConfiguration.setString(key, value);
      }
    }
  }