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();
}
}