public void processElement()

in java/dataflow-connector-examples/src/main/java/com/google/cloud/bigtable/dataflow/example/PubsubWordCount.java [100:107]

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

    public void processElement(ProcessContext c) {
      Instant timestamp = c.timestamp();
      for (String word : c.element().split("[^a-zA-Z']+")) {
        if (!word.isEmpty()) {
          c.output(word + "|" + timestamp);
        }
      }
    }