private static PlaygroundIngressSpec asPlaygroundIngressSpec()

in playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/PlaygroundSourceProvider.java [16:22]

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

  private static <T> PlaygroundIngressSpec asPlaygroundIngressSpec(IngressSpec<T> spec) {
    if (spec instanceof PlaygroundIngressSpec) {
      return (PlaygroundIngressSpec) spec;
    }

    throw new IllegalArgumentException(String.format("Unknown ingress spec %s", spec));
  }