void validate()

in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsUniverseValidator.java [22:37]

• 15 lines of code
• 6 McCabe index (conditional complexity)

  void validate(StatefulFunctionsUniverse statefulFunctionsUniverse) {
    // TODO: complete this
    if (statefulFunctionsUniverse.ingress().isEmpty()) {
      throw new IllegalStateException("There are no ingress defined.");
    }
    if (statefulFunctionsUniverse.sources().isEmpty()) {
      throw new IllegalStateException("There are no source providers defined.");
    }
    if (statefulFunctionsUniverse.routers().isEmpty()) {
      throw new IllegalStateException("There are no routers defined.");
    }
    if (statefulFunctionsUniverse.functions().isEmpty()
        && statefulFunctionsUniverse.namespaceFunctions().isEmpty()) {
      throw new IllegalStateException("There are no function providers defined.");
    }
  }