public void parseStringToLogElement()

in processor/src/main/java/com/google/cloud/solutions/realtimedash/pipeline/ParseMessageAsLogElement.java [36:42]


  public void parseStringToLogElement(ProcessContext context) {
    try {
      context.output(buildReader().readValue(context.element()));
    } catch (IOException ioexp) {
      logger.atWarning().atMostEvery(10, TimeUnit.SECONDS).withCause(ioexp).log();
    }
  }