v1.18.0

Author: Anush008

gradle.properties

@@ -1,8 +1,8 @@
 # The version of qdrant to use to download protos
-qdrantProtosVersion=v1.17.0
+qdrantProtosVersion=dev
 
 # The version of qdrant docker image to run integration tests against
-qdrantVersion=v1.17.0
+qdrantVersion=dev
 
 # The version of the client to generate
-packageVersion=1.17.0
+packageVersion=1.18.0

src/main/java/io/qdrant/client/QdrantClient.java

@@ -55,10 +55,12 @@
 import io.qdrant.client.grpc.Points.CountPoints;
 import io.qdrant.client.grpc.Points.CountResponse;
 import io.qdrant.client.grpc.Points.CreateFieldIndexCollection;
+import io.qdrant.client.grpc.Points.CreateVectorNameRequest;
 import io.qdrant.client.grpc.Points.DeleteFieldIndexCollection;
 import io.qdrant.client.grpc.Points.DeletePayloadPoints;
 import io.qdrant.client.grpc.Points.DeletePointVectors;
 import io.qdrant.client.grpc.Points.DeletePoints;
+import io.qdrant.client.grpc.Points.DeleteVectorNameRequest;
 import io.qdrant.client.grpc.Points.DiscoverBatchPoints;
 import io.qdrant.client.grpc.Points.DiscoverBatchResponse;
 import io.qdrant.client.grpc.Points.DiscoverPoints;
@@ -2348,6 +2350,60 @@ public ListenableFuture<UpdateResult> deletePayloadIndexAsync(
         future, PointsOperationResponse::getResult, MoreExecutors.directExecutor());
   }
 
+  /**
+   * Creates a new named vector on a collection.
+   *
+   * @param request The create vector name request.
+   * @return a new instance of {@link ListenableFuture}
+   */
+  public ListenableFuture<UpdateResult> createVectorNameAsync(CreateVectorNameRequest request) {
+    return createVectorNameAsync(request, null);
+  }
+
+  /**
+   * Creates a new named vector on a collection.
+   *
+   * @param request The create vector name request.
+   * @param timeout The timeout for the call.
+   * @return a new instance of {@link ListenableFuture}
+   */
+  public ListenableFuture<UpdateResult> createVectorNameAsync(
+      CreateVectorNameRequest request, @Nullable Duration timeout) {
+    logger.debug(
+        "Create vector name '{}' in '{}'", request.getVectorName(), request.getCollectionName());
+    ListenableFuture<PointsOperationResponse> future = getPoints(timeout).createVectorName(request);
+    addLogFailureCallback(future, "Create vector name");
+    return Futures.transform(
+        future, PointsOperationResponse::getResult, MoreExecutors.directExecutor());
+  }
+
+  /**
+   * Deletes a named vector from a collection.
+   *
+   * @param request The delete vector name request.
+   * @return a new instance of {@link ListenableFuture}
+   */
+  public ListenableFuture<UpdateResult> deleteVectorNameAsync(DeleteVectorNameRequest request) {
+    return deleteVectorNameAsync(request, null);
+  }
+
+  /**
+   * Deletes a named vector from a collection.
+   *
+   * @param request The delete vector name request.
+   * @param timeout The timeout for the call.
+   * @return a new instance of {@link ListenableFuture}
+   */
+  public ListenableFuture<UpdateResult> deleteVectorNameAsync(
+      DeleteVectorNameRequest request, @Nullable Duration timeout) {
+    logger.debug(
+        "Delete vector name '{}' in '{}'", request.getVectorName(), request.getCollectionName());
+    ListenableFuture<PointsOperationResponse> future = getPoints(timeout).deleteVectorName(request);
+    addLogFailureCallback(future, "Delete vector name");
+    return Futures.transform(
+        future, PointsOperationResponse::getResult, MoreExecutors.directExecutor());
+  }
+
   /**
    * Retrieves closest points based on vector similarity and the given filtering conditions.
    *

src/test/java/io/qdrant/client/CollectionsTest.java

@@ -18,6 +18,9 @@
 import io.qdrant.client.grpc.Collections.Distance;
 import io.qdrant.client.grpc.Collections.VectorParams;
 import io.qdrant.client.grpc.Collections.VectorsConfig;
+import io.qdrant.client.grpc.Points.CreateVectorNameRequest;
+import io.qdrant.client.grpc.Points.DeleteVectorNameRequest;
+import io.qdrant.client.grpc.Points.DenseVectorCreationConfig;
 import java.util.Comparator;
 import java.util.List;
 import java.util.concurrent.ExecutionException;
@@ -264,4 +267,53 @@ public void deleteAlias() throws ExecutionException, InterruptedException {
     List<String> aliases = client.listCollectionAliasesAsync(testName).get();
     assertTrue(aliases.isEmpty());
   }
+
+  @Test
+  public void createAndDeleteVector() throws ExecutionException, InterruptedException {
+    CreateCollection createCollection = getCreateCollection(testName);
+    client.createCollectionAsync(createCollection).get();
+
+    client
+        .createVectorNameAsync(
+            CreateVectorNameRequest.newBuilder()
+                .setCollectionName(testName)
+                .setVectorName("vector_1")
+                .setDenseConfig(
+                    DenseVectorCreationConfig.newBuilder()
+                        .setSize(8)
+                        .setDistance(Distance.Cosine)
+                        .build())
+                .setWait(true)
+                .build())
+        .get();
+
+    assertTrue(
+        client
+            .getCollectionInfoAsync(testName)
+            .get()
+            .getConfig()
+            .getParams()
+            .getVectorsConfig()
+            .getParamsMap()
+            .containsMap("vector_1"));
+
+    client
+        .deleteVectorNameAsync(
+            DeleteVectorNameRequest.newBuilder()
+                .setCollectionName(testName)
+                .setVectorName("vector_1")
+                .setWait(true)
+                .build())
+        .get();
+
+    assertFalse(
+        client
+            .getCollectionInfoAsync(testName)
+            .get()
+            .getConfig()
+            .getParams()
+            .getVectorsConfig()
+            .getParamsMap()
+            .containsMap("vector_1"));
+  }
 }