chore: throw on invalid ID type

qdrant · Feb 28, 2024 · eb7fe9b · eb7fe9b
1 parent d382438
commit eb7fe9b
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/io/qdrant/spark/QdrantDataWriter.java b/src/main/java/io/qdrant/spark/QdrantDataWriter.java
@@ -69,8 +69,9 @@ public void write(InternalRow record) {
           case "long":
             pointBuilder.setId(id(record.getInt(fieldIndex)));
             break;
+
           default:
-            break;
+            throw new IllegalArgumentException("Point ID should be of type string or integer");
         }
 
       } else if (field.name().equals(this.options.embeddingField)) {