From ab522de4d4cdd9e8e94e844e4ba800fe2cbd34a2 Mon Sep 17 00:00:00 2001
From: Sunjeet <sstattla@yahoo.com>
Date: Tue, 12 Mar 2024 17:04:34 -0700
Subject: [PATCH] Revert "Add support for byte arrays in primary key of
 history"

This reverts commit 0aca0214e29374a6bded16c328c010e447355196.
---
 .../netflix/hollow/tools/diff/HollowDiff.java |  2 +-
 .../hollow/tools/util/ObjectInternPool.java   |  8 +-----
 .../hollow/tools/util/SearchUtils.java        |  3 +--
 .../tools/util/ObjectInternPoolTest.java      | 27 -------------------
 4 files changed, 3 insertions(+), 37 deletions(-)

diff --git a/hollow/src/main/java/com/netflix/hollow/tools/diff/HollowDiff.java b/hollow/src/main/java/com/netflix/hollow/tools/diff/HollowDiff.java
index fe076c2562..69d0f5981c 100644
--- a/hollow/src/main/java/com/netflix/hollow/tools/diff/HollowDiff.java
+++ b/hollow/src/main/java/com/netflix/hollow/tools/diff/HollowDiff.java
@@ -43,7 +43,7 @@
  *
  */
 public class HollowDiff {
-    private final EnumSet<FieldType> SINGLE_FIELD_SUPPORTED_TYPES = EnumSet.of(FieldType.INT, FieldType.LONG, FieldType.DOUBLE, FieldType.STRING, FieldType.FLOAT, FieldType.BOOLEAN, FieldType.BYTES);
+    private final EnumSet<FieldType> SINGLE_FIELD_SUPPORTED_TYPES = EnumSet.of(FieldType.INT, FieldType.LONG, FieldType.DOUBLE, FieldType.STRING, FieldType.FLOAT, FieldType.BOOLEAN);
 
     private final Logger log = Logger.getLogger(HollowDiff.class.getName());
     private final HollowReadStateEngine fromStateEngine;
diff --git a/hollow/src/main/java/com/netflix/hollow/tools/util/ObjectInternPool.java b/hollow/src/main/java/com/netflix/hollow/tools/util/ObjectInternPool.java
index 94a16c9267..af0fb18c5e 100644
--- a/hollow/src/main/java/com/netflix/hollow/tools/util/ObjectInternPool.java
+++ b/hollow/src/main/java/com/netflix/hollow/tools/util/ObjectInternPool.java
@@ -49,8 +49,6 @@ public Object getObject(int ordinal, FieldType type) {
                 return getLong(pointer);
             case STRING:
                 return getString(pointer);
-            case BYTES:
-                return getBytes(pointer);
             default:
                 throw new IllegalArgumentException("Unknown type " + type);
         }
@@ -84,17 +82,13 @@ public long getLong(long pointer) {
     }
 
     public String getString(long pointer) {
-        return new String(getBytes(pointer));
-    }
-
-    public byte[] getBytes(long pointer) {
         ByteData byteData = ordinalMap.getByteData().getUnderlyingArray();
         int length = VarInt.readVInt(byteData, pointer);
         byte[] bytes = new byte[length];
         for(int i=0;i<length;i++) {
             bytes[i] = byteData.get(pointer+1+i);
         }
-        return bytes;
+        return new String(bytes);
     }
 
     public int writeAndGetOrdinal(Object objectToIntern) {
diff --git a/hollow/src/main/java/com/netflix/hollow/tools/util/SearchUtils.java b/hollow/src/main/java/com/netflix/hollow/tools/util/SearchUtils.java
index 4ce61cefd5..3cdb0ce546 100644
--- a/hollow/src/main/java/com/netflix/hollow/tools/util/SearchUtils.java
+++ b/hollow/src/main/java/com/netflix/hollow/tools/util/SearchUtils.java
@@ -58,8 +58,7 @@ public static Object[] parseKey(HollowReadStateEngine readStateEngine, PrimaryKe
                     key[i] = Float.parseFloat(fields[i]);
                     break;
                 case BYTES:
-                    key[i] = fields[i];
-                    break;
+                    throw new IllegalArgumentException("Primary key contains a field of type BYTES");
             }
         }
         return key;
diff --git a/hollow/src/test/java/com/netflix/hollow/tools/util/ObjectInternPoolTest.java b/hollow/src/test/java/com/netflix/hollow/tools/util/ObjectInternPoolTest.java
index d713acc0f2..42f4a6a98a 100644
--- a/hollow/src/test/java/com/netflix/hollow/tools/util/ObjectInternPoolTest.java
+++ b/hollow/src/test/java/com/netflix/hollow/tools/util/ObjectInternPoolTest.java
@@ -16,7 +16,6 @@
  */
 package com.netflix.hollow.tools.util;
 
-import static org.junit.Assert.assertArrayEquals;
 import static org.junit.Assert.assertEquals;
 import com.netflix.hollow.core.schema.HollowObjectSchema.FieldType;
 
@@ -163,32 +162,6 @@ public void testString() {
         assertEquals(retrievedString2, "I can do this all day");
     }
 
-    @Test
-    public void testBytes() {
-        byte[] bytesObj1 = "I am Groot".getBytes();
-        byte[] bytesObj2 = "I am Groot".getBytes();
-        byte[] bytesObj3 = "I can do this all day".getBytes();
-        byte[] bytesObj4 = "I can do this all day".getBytes();
-
-        int bytes1Ordinal = internPool.writeAndGetOrdinal(bytesObj1);
-        int bytes2Ordinal = internPool.writeAndGetOrdinal(bytesObj2);
-        internPool.prepareForRead();
-
-        byte[] retrievedString1 = (byte[]) internPool.getObject(bytes1Ordinal, FieldType.BYTES);
-
-        assertEquals(bytes1Ordinal, bytes2Ordinal);
-        assertArrayEquals(retrievedString1, "I am Groot".getBytes());
-
-        int bytes3Ordinal = internPool.writeAndGetOrdinal(bytesObj3);
-        int bytes4Ordinal = internPool.writeAndGetOrdinal(bytesObj4);
-        internPool.prepareForRead();
-
-        byte[] retrievedBytes2 = (byte[]) internPool.getObject(bytes3Ordinal, FieldType.BYTES);
-
-        assertEquals(bytes3Ordinal, bytes4Ordinal);
-        assertArrayEquals(retrievedBytes2, "I can do this all day".getBytes());
-    }
-
     @Test
     public void testBool() {
         Boolean boolObj1 = true;