public void processElement()

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