private EgressRecord asEgressRecord()

in playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/PlaygroundEgress.java [48:57]

• 9 lines of code
• 3 McCabe index (conditional complexity)

  private EgressRecord asEgressRecord(T value) throws IOException {
    if (value instanceof TypedValue) {
      final TypedValue typedValue = ((TypedValue) value);

      if (typedValue.getTypename().equals(Constants.PLAYGROUND_EGRESS_RECORD)) {
        return objectMapper.readValue(typedValue.getValue().toByteArray(), EgressRecord.class);
      }
    }
    throw new IllegalArgumentException(String.format("Received unexpected value %s.", value));
  }