public void process()

in src/main/java/com/google/solutions/df/log/aggregations/common/fraud/detection/PredictTransform.java [173:181]

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

    public void process(
        @Element KV<Integer, String> element,
        @StateId("elementsBag") BagState<String> elementsBag,
        @TimerId("eventTimer") Timer eventTimer,
        BoundedWindow w) {
      LOG.debug("Key {}", element.getKey());
      elementsBag.add(element.getValue());
      eventTimer.set(w.maxTimestamp());
    }