in src/main/java/com/google/solutions/df/log/aggregations/common/fraud/detection/ReadTransactionTransform.java [103:114]
public void processElement(ProcessContext c) {
String input = c.element();
try {
JsonObject convertedObject = gson.fromJson(input, JsonObject.class);
numberOfTransProcessed.inc();
c.output(Util.successJsonTag, convertedObject.toString());
LOG.debug("log: {}", convertedObject.toString());
} catch (JsonSyntaxException ex) {
c.output(Util.failedJsonTag, input);
LOG.error("Error Parsing Json {}", ex.getMessage());
}
}