Fix to suppress warnings

Author: KodaiD

core/src/main/java/com/scalar/db/storage/objectstorage/ObjectStoragePartition.java

@@ -61,11 +61,11 @@ public boolean isEmpty() {
   public void applyPut(Put put, TableMetadata tableMetadata) throws NoMutationException {
     ObjectStorageMutation mutation = new ObjectStorageMutation(put, tableMetadata);
     if (!put.getCondition().isPresent()) {
-      if (!records.containsKey(mutation.getRecordId())) {
+      ObjectStorageRecord existingRecord = records.get(mutation.getRecordId());
+      if (existingRecord == null) {
         records.put(mutation.getRecordId(), mutation.makeRecord());
       } else {
-        records.compute(
-            mutation.getRecordId(), (id, existingRecord) -> mutation.makeRecord(existingRecord));
+        records.put(mutation.getRecordId(), mutation.makeRecord(existingRecord));
       }
     } else if (put.getCondition().get() instanceof PutIfNotExists) {
       if (records.containsKey(mutation.getRecordId())) {
@@ -74,12 +74,12 @@ public void applyPut(Put put, TableMetadata tableMetadata) throws NoMutationExce
       }
       records.put(mutation.getRecordId(), mutation.makeRecord());
     } else if (put.getCondition().get() instanceof PutIfExists) {
-      if (!records.containsKey(mutation.getRecordId())) {
+      ObjectStorageRecord existingRecord = records.get(mutation.getRecordId());
+      if (existingRecord == null) {
         throw new NoMutationException(
             CoreError.NO_MUTATION_APPLIED.buildMessage(), Collections.singletonList(put));
       }
-      records.compute(
-          mutation.getRecordId(), (id, existingRecord) -> mutation.makeRecord(existingRecord));
+      records.put(mutation.getRecordId(), mutation.makeRecord(existingRecord));
     } else {
       assert put.getCondition().get() instanceof PutIf;
       if (!records.containsKey(mutation.getRecordId())) {

core/src/main/java/com/scalar/db/storage/objectstorage/StreamingRecordIterator.java

@@ -2,6 +2,7 @@
 
 import com.scalar.db.common.CoreError;
 import com.scalar.db.exception.storage.ExecutionException;
+import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
 import java.util.Collections;
 import java.util.Iterator;
 import java.util.List;
@@ -11,6 +12,7 @@
  * Iterator that streams records from partitions in a lazy manner, loading partitions on-demand
  * instead of loading all records into memory at once.
  */
+@SuppressFBWarnings("EI_EXPOSE_REP2")
 public class StreamingRecordIterator implements Iterator<ObjectStorageRecord> {
   private final ObjectStorageWrapper wrapper;
   private final String namespaceName;