public void addUpdateOperation()

in src/main/java/org/apache/geode/kafka/sink/BatchRecords.java [57:65]

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

  public void addUpdateOperation(SinkRecord record, boolean nullValuesMeansRemove) {
    // it's assumed the records in are order
    // if so then a previous value was in the remove list
    // let's not remove it at the end of this operation
    if (nullValuesMeansRemove) {
      removeList.remove(record.key());
    }
    updateMap.put(record.key(), record.value());
  }