public void addRemoveOperation()

in src/main/java/org/apache/geode/kafka/sink/BatchRecords.java [45:55]

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

  public void addRemoveOperation(SinkRecord record) {
    // if a previous operation added to the update map
    // let's just remove it so, we don't do a put and then a remove
    // depending on the order of operations (putAll then removeAll or putAll)...
    // ...we could remove one of the if statements.
    if (updateMap.containsKey(record.key())) {
      updateMap.remove(record.key());
    } else {
      removeList.add(record.key());
    }
  }