public void process()

in src/main/java/com/google/solutions/df/log/aggregations/common/DLPTransform.java [132:139]

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

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