public void processElement()

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

• 13 lines of code
• 2 McCabe index (conditional complexity)

    public void processElement(ProcessContext c) {

      Row row = c.element().getValue();
      Double millisTosecs = (c.timestamp().getMillis() * 0.001);
      String key = c.element().getKey().concat("_" + String.valueOf(millisTosecs.intValue()));
      Iterator<Object> rowItr = row.getValues().iterator();
      Table.Row.Builder tableRowBuilder = Table.Row.newBuilder();
      while (rowItr.hasNext()) {
        tableRowBuilder.addValues(Value.newBuilder().setStringValue(rowItr.next().toString()));
      }
      Table.Row dlpRow = tableRowBuilder.build();
      LOG.debug("Key {}, DLPRow {}", key, dlpRow);
      c.output(KV.of(key, dlpRow));
    }