synchronized void mutate()

in flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/sink/HBaseSinkFunction.java [288:294]

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

        synchronized void mutate(Mutation current) {
            ByteBuffer key = ByteBuffer.wrap(current.getRow());
            Mutation old = mutations.get(key);
            if (old == null || current.getTimeStamp() >= old.getTimeStamp()) {
                mutations.put(key, current);
            }
        }