From 045ab77e95b62ad1a98341ab11c2d1d858cc1ef1 Mon Sep 17 00:00:00 2001
From: Sunjeet Singh <sunjeets@netflix.com>
Date: Thu, 6 Feb 2025 14:47:44 -0800
Subject: [PATCH] More cleanup for PR

---
 .../HollowObjectTypeReadStateShard.java       | 49 -------------------
 .../hollow/core/write/HollowBlobWriter.java   |  1 +
 .../core/write/HollowListTypeWriteState.java  |  2 -
 .../write/HollowObjectTypeWriteState.java     |  2 +-
 4 files changed, 2 insertions(+), 52 deletions(-)

diff --git a/hollow/src/main/java/com/netflix/hollow/core/read/engine/object/HollowObjectTypeReadStateShard.java b/hollow/src/main/java/com/netflix/hollow/core/read/engine/object/HollowObjectTypeReadStateShard.java
index becaa4bce..fe3745f45 100644
--- a/hollow/src/main/java/com/netflix/hollow/core/read/engine/object/HollowObjectTypeReadStateShard.java
+++ b/hollow/src/main/java/com/netflix/hollow/core/read/engine/object/HollowObjectTypeReadStateShard.java
@@ -244,61 +244,12 @@ protected void applyShardToChecksum(HollowChecksum checksum, HollowSchema withSc
                         checksum.applyInt(findVarLengthFieldHashCode(startByte, endByte, numBitsForField, fieldIdx));
                     }
                 }
-                // if (withSchema.getName().equals("TestObject")) {
-                //     System.out.println("SNAP: DEBUG: checksum=" + checksum + " ordinal= " + ordinal);
-                // }
             }
 
             ordinal = populatedOrdinals.nextSetBit(ordinal + 1);
         }
     }
 
-    protected void applyOrdinalToChecksum(HollowChecksum checksum, HollowSchema withSchema, int ordinal, int shardOrdinal) {
-        int numBitsForField;
-        long bitOffset;
-        long endByte;
-        long startByte;
-
-        if(!(withSchema instanceof HollowObjectSchema))
-            throw new IllegalArgumentException("HollowObjectTypeReadState can only calculate checksum with a HollowObjectSchema: " + schema.getName());
-
-        HollowObjectSchema commonSchema = schema.findCommonSchema((HollowObjectSchema)withSchema);
-
-        List<String> commonFieldNames = new ArrayList<String>();
-        for(int i=0;i<commonSchema.numFields();i++)
-            commonFieldNames.add(commonSchema.getFieldName(i));
-        Collections.sort(commonFieldNames);
-
-        int fieldIndexes[] = new int[commonFieldNames.size()];
-        for(int i=0;i<commonFieldNames.size();i++) {
-            fieldIndexes[i] = schema.getPosition(commonFieldNames.get(i));
-        }
-
-        checksum.applyInt(ordinal);
-        for(int i=0;i<fieldIndexes.length;i++) {
-            int fieldIdx = fieldIndexes[i];
-            bitOffset = fieldOffset(shardOrdinal, fieldIdx);
-            numBitsForField = dataElements.bitsPerField[fieldIdx];
-            if(!schema.getFieldType(fieldIdx).isVariableLength()) {
-                long fixedLengthValue = numBitsForField <= 56 ?
-                        dataElements.fixedLengthData.getElementValue(bitOffset, numBitsForField)
-                        : dataElements.fixedLengthData.getLargeElementValue(bitOffset, numBitsForField);
-
-                if(fixedLengthValue == dataElements.nullValueForField[fieldIdx])
-                    checksum.applyInt(Integer.MAX_VALUE);
-                else
-                    checksum.applyLong(fixedLengthValue);
-            } else {
-                endByte = dataElements.fixedLengthData.getElementValue(bitOffset, numBitsForField);
-                startByte = shardOrdinal != 0 ? dataElements.fixedLengthData.getElementValue(bitOffset - dataElements.bitsPerRecord, numBitsForField) : 0;
-                checksum.applyInt(findVarLengthFieldHashCode(startByte, endByte, numBitsForField, fieldIdx));
-            }
-        }
-        if (withSchema.getName().equals("TestObject")) {
-            System.out.println("SNAP: DEBUG: checksum=" + checksum + " ordinal= " + ordinal);
-        }
-    }
-
     public long getApproximateHeapFootprintInBytes() {
         long bitsPerFixedLengthData = (long)dataElements.bitsPerRecord * (dataElements.maxOrdinal + 1);
         
diff --git a/hollow/src/main/java/com/netflix/hollow/core/write/HollowBlobWriter.java b/hollow/src/main/java/com/netflix/hollow/core/write/HollowBlobWriter.java
index 48cbd1982..be357fbb1 100644
--- a/hollow/src/main/java/com/netflix/hollow/core/write/HollowBlobWriter.java
+++ b/hollow/src/main/java/com/netflix/hollow/core/write/HollowBlobWriter.java
@@ -133,6 +133,7 @@ public void writeDelta(OutputStream os, ProducerOptionalBlobPartConfig.OptionalB
             partStreamsByType = partStreams.getStreamsByType();
 
         stateEngine.prepareForWrite();
+
         if(stateEngine.isRestored())
             stateEngine.ensureAllNecessaryStatesRestored();
 
diff --git a/hollow/src/main/java/com/netflix/hollow/core/write/HollowListTypeWriteState.java b/hollow/src/main/java/com/netflix/hollow/core/write/HollowListTypeWriteState.java
index 9ffb93b4b..0d95e5328 100644
--- a/hollow/src/main/java/com/netflix/hollow/core/write/HollowListTypeWriteState.java
+++ b/hollow/src/main/java/com/netflix/hollow/core/write/HollowListTypeWriteState.java
@@ -25,10 +25,8 @@
 import com.netflix.hollow.core.schema.HollowListSchema;
 import java.io.DataOutputStream;
 import java.io.IOException;
-import java.util.logging.Logger;
 
 public class HollowListTypeWriteState extends HollowTypeWriteState {
-    private static final Logger LOG = Logger.getLogger(HollowListTypeWriteState.class.getName());
 
     /// statistics required for writing fixed length list data
     private int bitsPerListPointer;
diff --git a/hollow/src/main/java/com/netflix/hollow/core/write/HollowObjectTypeWriteState.java b/hollow/src/main/java/com/netflix/hollow/core/write/HollowObjectTypeWriteState.java
index b29d30e7b..4d98317e0 100644
--- a/hollow/src/main/java/com/netflix/hollow/core/write/HollowObjectTypeWriteState.java
+++ b/hollow/src/main/java/com/netflix/hollow/core/write/HollowObjectTypeWriteState.java
@@ -194,7 +194,7 @@ public void calculateSnapshot() {
     }
 
     public void writeSnapshot(DataOutputStream os) throws IOException {
-        LOG.log(Level.INFO, String.format("Writing snapshot with num shards = %s, revNumShards = %s, max shard ordinals = %s", numShards, revNumShards, Arrays.toString(maxShardOrdinal)));
+        LOG.log(Level.FINE, String.format("Writing snapshot with num shards = %s, revNumShards = %s, max shard ordinals = %s", numShards, revNumShards, Arrays.toString(maxShardOrdinal)));
         /// for unsharded blobs, support pre v2.1.0 clients
         if(numShards == 1) {
             writeSnapshotShard(os, 0);