Package io.qdrant.client

Class QdrantClient

java.lang.Object
io.qdrant.client.QdrantClient
All Implemented Interfaces:
AutoCloseable
public class QdrantClient extends Object implements AutoCloseable
Client for the Qdrant vector database.

  • Constructor Summary

    Constructors
    Constructor
    Description
    QdrantClient(QdrantGrpcClient grpcClient)
    Creates a new instance of QdrantClient

  • Method Summary

    Modifier and Type
    Method
    Description
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.UpdateResult>>
    batchUpdateAsync(io.qdrant.client.grpc.Points.UpdateBatchPoints request, Duration timeout)
    Performs a batch update of points.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.UpdateResult>>
    batchUpdateAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointsUpdateOperation> operations)
    Performs a batch update of points.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.UpdateResult>>
    batchUpdateAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointsUpdateOperation> operations, Boolean wait, io.qdrant.client.grpc.Points.WriteOrdering ordering, Duration timeout)
    Performs a batch update of points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    clearPayloadAsync(io.qdrant.client.grpc.Points.ClearPayloadPoints request, Duration timeout)
    Removes all payload for the points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    clearPayloadAsync(String collectionName, io.qdrant.client.grpc.Points.Filter filter, Boolean wait, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Removes all payload for the filtered points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    clearPayloadAsync(String collectionName, io.qdrant.client.grpc.Points.PointId id, Boolean wait, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Removes all payload for the given id.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    clearPayloadAsync(String collectionName, io.qdrant.client.grpc.Points.PointsSelector pointsSelector, Boolean wait, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Removes all payload for the points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    clearPayloadAsync(String collectionName, Boolean wait, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Remove all payload for all points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    clearPayloadAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointId> ids, Boolean wait, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Removes all payload for the given ids.
    void
    close()
     
    com.google.common.util.concurrent.ListenableFuture<Boolean>
    collectionExistsAsync(String collectionName)
    Check if a collection exists
    com.google.common.util.concurrent.ListenableFuture<Boolean>
    collectionExistsAsync(String collectionName, Duration timeout)
    Check if a collection exists
    com.google.common.util.concurrent.ListenableFuture<Long>
    countAsync(String collectionName)
    Count the points in a collection.
    com.google.common.util.concurrent.ListenableFuture<Long>
    countAsync(String collectionName, io.qdrant.client.grpc.Points.Filter filter, Boolean exact)
    Count the points in a collection with the given filtering conditions.
    com.google.common.util.concurrent.ListenableFuture<Long>
    countAsync(String collectionName, io.qdrant.client.grpc.Points.Filter filter, Boolean exact, Duration timeout)
    Count the points in a collection with the given filtering conditions.
    com.google.common.util.concurrent.ListenableFuture<Long>
    countAsync(String collectionName, Duration timeout)
    Count the points in a collection.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse>
    createAliasAsync(String aliasName, String collectionName)
    Creates an alias for a given collection.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse>
    createAliasAsync(String aliasName, String collectionName, Duration timeout)
    Creates an alias for a given collection.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse>
    createCollectionAsync(io.qdrant.client.grpc.Collections.CreateCollection createCollection)
    Creates a new collection with the given parameters
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse>
    createCollectionAsync(io.qdrant.client.grpc.Collections.CreateCollection createCollection, Duration timeout)
    Creates a new collection with the given parameters
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse>
    createCollectionAsync(String collectionName, io.qdrant.client.grpc.Collections.VectorParams vectorParams)
    Creates a new collection with the given parameters
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse>
    createCollectionAsync(String collectionName, io.qdrant.client.grpc.Collections.VectorParams vectorParams, Duration timeout)
    Creates a new collection with the given parameters
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse>
    createCollectionAsync(String collectionName, Map<String,io.qdrant.client.grpc.Collections.VectorParams> namedVectorParams)
    Creates a new collection with the given parameters
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse>
    createCollectionAsync(String collectionName, Map<String,io.qdrant.client.grpc.Collections.VectorParams> namedVectorParams, Duration timeout)
    Creates a new collection with the given parameters
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.SnapshotsService.SnapshotDescription>
    createFullSnapshotAsync()
    Create snapshot for a whole storage.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.SnapshotsService.SnapshotDescription>
    createFullSnapshotAsync(Duration timeout)
    Create snapshot for a whole storage.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    createPayloadIndexAsync(io.qdrant.client.grpc.Points.CreateFieldIndexCollection request, Duration timeout)
    Creates a payload field index in a collection.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    createPayloadIndexAsync(String collectionName, String field, io.qdrant.client.grpc.Collections.PayloadSchemaType schemaType, io.qdrant.client.grpc.Collections.PayloadIndexParams indexParams, Boolean wait, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Creates a payload field index in a collection.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CreateShardKeyResponse>
    createShardKeyAsync(io.qdrant.client.grpc.Collections.CreateShardKeyRequest createShardKey)
    Creates a shard key for a collection.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CreateShardKeyResponse>
    createShardKeyAsync(io.qdrant.client.grpc.Collections.CreateShardKeyRequest createShardKey, Duration timeout)
    Creates a shard key for a collection.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.SnapshotsService.SnapshotDescription>
    createSnapshotAsync(String collectionName)
    Create snapshot for a given collection.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.SnapshotsService.SnapshotDescription>
    createSnapshotAsync(String collectionName, Duration timeout)
    Create snapshot for a given collection.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse>
    deleteAliasAsync(String aliasName)
    Deletes an alias.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse>
    deleteAliasAsync(String aliasName, Duration timeout)
    Deletes an alias.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    deleteAsync(io.qdrant.client.grpc.Points.DeletePoints request)
    Deletes points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    deleteAsync(io.qdrant.client.grpc.Points.DeletePoints request, Duration timeout)
    Deletes points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    deleteAsync(String collectionName, io.qdrant.client.grpc.Points.Filter filter)
    Deletes points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    deleteAsync(String collectionName, io.qdrant.client.grpc.Points.Filter filter, Duration timeout)
    Deletes points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    deleteAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointId> ids)
    Deletes points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    deleteAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointId> ids, Duration timeout)
    Deletes points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse>
    deleteCollectionAsync(String collectionName)
    Deletes a collection and all its associated data.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse>
    deleteCollectionAsync(String collectionName, Duration timeout)
    Deletes a collection and all its associated data.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.SnapshotsService.DeleteSnapshotResponse>
    deleteFullSnapshotAsync(String snapshotName)
    Delete snapshot for a whole storage.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.SnapshotsService.DeleteSnapshotResponse>
    deleteFullSnapshotAsync(String snapshotName, Duration timeout)
    Delete snapshot for a whole storage.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    deletePayloadAsync(io.qdrant.client.grpc.Points.DeletePayloadPoints request, Duration timeout)
    Delete specified key payload for the points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    deletePayloadAsync(String collectionName, List<String> keys, io.qdrant.client.grpc.Points.Filter filter, Boolean wait, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Delete specified key payload for the filtered points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    deletePayloadAsync(String collectionName, List<String> keys, io.qdrant.client.grpc.Points.PointId id, Boolean wait, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Delete specified key payload for the given id.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    deletePayloadAsync(String collectionName, List<String> keys, io.qdrant.client.grpc.Points.PointsSelector pointsSelector, Boolean wait, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Delete specified key payload for the points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    deletePayloadAsync(String collectionName, List<String> keys, Boolean wait, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Delete specified key payload for all points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    deletePayloadAsync(String collectionName, List<String> keys, List<io.qdrant.client.grpc.Points.PointId> ids, Boolean wait, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Delete specified key payload for the given ids.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    deletePayloadIndexAsync(String collectionName, String field, Boolean wait, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Deletes a payload field index in a collection.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.DeleteShardKeyResponse>
    deleteShardKeyAsync(io.qdrant.client.grpc.Collections.DeleteShardKeyRequest deleteShardKey)
    Deletes a shard key for a collection.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.DeleteShardKeyResponse>
    deleteShardKeyAsync(io.qdrant.client.grpc.Collections.DeleteShardKeyRequest deleteShardKey, Duration timeout)
    Deletes a shard key for a collection.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.SnapshotsService.DeleteSnapshotResponse>
    deleteSnapshotAsync(String collectionName, String snapshotName)
    Delete snapshot for a given collection.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.SnapshotsService.DeleteSnapshotResponse>
    deleteSnapshotAsync(String collectionName, String snapshotName, Duration timeout)
    Delete snapshot for a given collection.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    deleteVectorsAsync(io.qdrant.client.grpc.Points.DeletePointVectors request, Duration timeout)
    Delete named vectors for points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    deleteVectorsAsync(String collectionName, List<String> vectors, io.qdrant.client.grpc.Points.Filter filter)
    Delete named vectors for points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    deleteVectorsAsync(String collectionName, List<String> vectors, io.qdrant.client.grpc.Points.Filter filter, Boolean wait, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Delete named vectors for points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    deleteVectorsAsync(String collectionName, List<String> vectors, io.qdrant.client.grpc.Points.Filter filter, Duration timeout)
    Delete named vectors for points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    deleteVectorsAsync(String collectionName, List<String> vectors, io.qdrant.client.grpc.Points.PointsSelector pointsSelector, Boolean wait, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Delete named vectors for points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    deleteVectorsAsync(String collectionName, List<String> vectors, List<io.qdrant.client.grpc.Points.PointId> ids)
    Delete named vectors for points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    deleteVectorsAsync(String collectionName, List<String> vectors, List<io.qdrant.client.grpc.Points.PointId> ids, Boolean wait, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Delete named vectors for points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    deleteVectorsAsync(String collectionName, List<String> vectors, List<io.qdrant.client.grpc.Points.PointId> ids, Duration timeout)
    Delete named vectors for points.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.ScoredPoint>>
    discoverAsync(io.qdrant.client.grpc.Points.DiscoverPoints request)
    Use the context and a target to find the most similar points to the target.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.ScoredPoint>>
    discoverAsync(io.qdrant.client.grpc.Points.DiscoverPoints request, Duration timeout)
    Use the context and a target to find the most similar points to the target.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.BatchResult>>
    discoverBatchAsync(String collectionName, List<io.qdrant.client.grpc.Points.DiscoverPoints> discoverSearches, io.qdrant.client.grpc.Points.ReadConsistency readConsistency)
    Use the context and a target to find the most similar points to the target in a batch.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.BatchResult>>
    discoverBatchAsync(String collectionName, List<io.qdrant.client.grpc.Points.DiscoverPoints> discoverSearches, io.qdrant.client.grpc.Points.ReadConsistency readConsistency, Duration timeout)
    Use the context and a target to find the most similar points to the target in a batch.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.FacetHit>>
    facetAsync(io.qdrant.client.grpc.Points.FacetCounts request)
    Perform facet counts.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.FacetHit>>
    facetAsync(io.qdrant.client.grpc.Points.FacetCounts request, Duration timeout)
    Perform facet counts.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionInfo>
    getCollectionInfoAsync(String collectionName)
    Gets detailed information about an existing collection.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionInfo>
    getCollectionInfoAsync(String collectionName, Duration timeout)
    Gets detailed information about an existing collection.
    QdrantGrpcClient
    grpcClient()
    Gets the low-level gRPC client.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.QdrantOuterClass.HealthCheckReply>
    healthCheckAsync()
    Gets detailed information about the qdrant cluster.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.QdrantOuterClass.HealthCheckReply>
    healthCheckAsync(Duration timeout)
    Gets detailed information about the qdrant cluster.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Collections.AliasDescription>>
    listAliasesAsync()
    Gets a list of all aliases for all existing collections.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Collections.AliasDescription>>
    listAliasesAsync(Duration timeout)
    Gets a list of all aliases for all existing collections.
    com.google.common.util.concurrent.ListenableFuture<List<String>>
    listCollectionAliasesAsync(String collectionName)
    Gets a list of all aliases for a collection.
    com.google.common.util.concurrent.ListenableFuture<List<String>>
    listCollectionAliasesAsync(String collectionName, Duration timeout)
    Gets a list of all aliases for a collection.
    com.google.common.util.concurrent.ListenableFuture<List<String>>
    listCollectionsAsync()
    Gets the names of all existing collections
    com.google.common.util.concurrent.ListenableFuture<List<String>>
    listCollectionsAsync(Duration timeout)
    Gets the names of all existing collections
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.SnapshotsService.SnapshotDescription>>
    listFullSnapshotAsync()
    Get list of snapshots for a whole storage.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.SnapshotsService.SnapshotDescription>>
    listFullSnapshotAsync(Duration timeout)
    Get list of snapshots for a whole storage.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.SnapshotsService.SnapshotDescription>>
    listSnapshotAsync(String collectionName)
    Get list of snapshots for a collection.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.SnapshotsService.SnapshotDescription>>
    listSnapshotAsync(String collectionName, Duration timeout)
    Get list of snapshots for a collection.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    overwritePayloadAsync(io.qdrant.client.grpc.Points.SetPayloadPoints request, Duration timeout)
    Overwrites the payload for the points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    overwritePayloadAsync(String collectionName, Map<String,io.qdrant.client.grpc.JsonWithInt.Value> payload, io.qdrant.client.grpc.Points.Filter filter, Boolean wait, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Overwrites the payload for the filtered points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    overwritePayloadAsync(String collectionName, Map<String,io.qdrant.client.grpc.JsonWithInt.Value> payload, io.qdrant.client.grpc.Points.PointId id, Boolean wait, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Overwrites the payload for the given id.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    overwritePayloadAsync(String collectionName, Map<String,io.qdrant.client.grpc.JsonWithInt.Value> payload, io.qdrant.client.grpc.Points.PointsSelector pointsSelector, Boolean wait, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Overwrites the payload for the points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    overwritePayloadAsync(String collectionName, Map<String,io.qdrant.client.grpc.JsonWithInt.Value> payload, io.qdrant.client.grpc.Points.PointsSelector pointsSelector, Boolean wait, String key, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Overwrites the payload for the points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    overwritePayloadAsync(String collectionName, Map<String,io.qdrant.client.grpc.JsonWithInt.Value> payload, Boolean wait, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Overwrites the payload for all points in the collection.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    overwritePayloadAsync(String collectionName, Map<String,io.qdrant.client.grpc.JsonWithInt.Value> payload, List<io.qdrant.client.grpc.Points.PointId> ids, Boolean wait, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Overwrites the payload for the given ids.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.ScoredPoint>>
    queryAsync(io.qdrant.client.grpc.Points.QueryPoints request)
    Universally query points.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.ScoredPoint>>
    queryAsync(io.qdrant.client.grpc.Points.QueryPoints request, Duration timeout)
    Universally query points.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.BatchResult>>
    queryBatchAsync(String collectionName, List<io.qdrant.client.grpc.Points.QueryPoints> queries)
    Universally query points in batch.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.BatchResult>>
    queryBatchAsync(String collectionName, List<io.qdrant.client.grpc.Points.QueryPoints> queries, io.qdrant.client.grpc.Points.ReadConsistency readConsistency)
    Universally query points in batch.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.BatchResult>>
    queryBatchAsync(String collectionName, List<io.qdrant.client.grpc.Points.QueryPoints> queries, io.qdrant.client.grpc.Points.ReadConsistency readConsistency, Duration timeout)
    Universally query points in batch.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.PointGroup>>
    queryGroupsAsync(io.qdrant.client.grpc.Points.QueryPointGroups request)
    Universally query points.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.PointGroup>>
    queryGroupsAsync(io.qdrant.client.grpc.Points.QueryPointGroups request, Duration timeout)
    Universally query points.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.ScoredPoint>>
    recommendAsync(io.qdrant.client.grpc.Points.RecommendPoints request)
    Look for the points which are closer to stored positive examples and at the same time further to negative examples.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.ScoredPoint>>
    recommendAsync(io.qdrant.client.grpc.Points.RecommendPoints request, Duration timeout)
    Look for the points which are closer to stored positive examples and at the same time further to negative examples.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.BatchResult>>
    recommendBatchAsync(String collectionName, List<io.qdrant.client.grpc.Points.RecommendPoints> recommendSearches, io.qdrant.client.grpc.Points.ReadConsistency readConsistency)
    Look for the points which are closer to stored positive examples and at the same time further to negative examples.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.BatchResult>>
    recommendBatchAsync(String collectionName, List<io.qdrant.client.grpc.Points.RecommendPoints> recommendSearches, io.qdrant.client.grpc.Points.ReadConsistency readConsistency, Duration timeout)
    Look for the points which are closer to stored positive examples and at the same time further to negative examples.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.PointGroup>>
    recommendGroupsAsync(io.qdrant.client.grpc.Points.RecommendPointGroups request)
    Look for the points which are closer to stored positive examples and at the same time further to negative examples, grouped by a given field
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.PointGroup>>
    recommendGroupsAsync(io.qdrant.client.grpc.Points.RecommendPointGroups request, Duration timeout)
    Look for the points which are closer to stored positive examples and at the same time further to negative examples, grouped by a given field
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse>
    recreateCollectionAsync(io.qdrant.client.grpc.Collections.CreateCollection createCollection)
    Deletes a collection if one exists, and creates a new collection with the given parameters.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse>
    recreateCollectionAsync(io.qdrant.client.grpc.Collections.CreateCollection createCollection, Duration timeout)
    Deletes a collection if one exists, and creates a new collection with the given parameters.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse>
    recreateCollectionAsync(String collectionName, io.qdrant.client.grpc.Collections.VectorParams vectorParams)
    Deletes a collection if one exists, and creates a new collection with the given parameters.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse>
    recreateCollectionAsync(String collectionName, io.qdrant.client.grpc.Collections.VectorParams vectorParams, Duration timeout)
    Deletes a collection if one exists, and creates a new collection with the given parameters.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse>
    recreateCollectionAsync(String collectionName, Map<String,io.qdrant.client.grpc.Collections.VectorParams> namedVectorParams)
    Deletes a collection if one exists, and creates a new collection with the given parameters.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse>
    recreateCollectionAsync(String collectionName, Map<String,io.qdrant.client.grpc.Collections.VectorParams> namedVectorParams, Duration timeout)
    Deletes a collection if one exists, and creates a new collection with the given parameters.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse>
    renameAliasAsync(String oldAliasName, String newAliasName)
    Renames an existing alias.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse>
    renameAliasAsync(String oldAliasName, String newAliasName, Duration timeout)
    Renames an existing alias.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.RetrievedPoint>>
    retrieveAsync(io.qdrant.client.grpc.Points.GetPoints request, Duration timeout)
    Retrieves points.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.RetrievedPoint>>
    retrieveAsync(String collectionName, io.qdrant.client.grpc.Points.PointId id, boolean withPayload, boolean withVectors, io.qdrant.client.grpc.Points.ReadConsistency readConsistency)
    Retrieves points.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.RetrievedPoint>>
    retrieveAsync(String collectionName, io.qdrant.client.grpc.Points.PointId id, io.qdrant.client.grpc.Points.ReadConsistency readConsistency)
    Retrieves points.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.RetrievedPoint>>
    retrieveAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointId> ids, boolean withPayload, boolean withVectors, io.qdrant.client.grpc.Points.ReadConsistency readConsistency)
    Retrieves points.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.RetrievedPoint>>
    retrieveAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointId> ids, io.qdrant.client.grpc.Points.ReadConsistency readConsistency)
    Retrieves points.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.RetrievedPoint>>
    retrieveAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointId> ids, io.qdrant.client.grpc.Points.WithPayloadSelector payloadSelector, io.qdrant.client.grpc.Points.WithVectorsSelector vectorsSelector, io.qdrant.client.grpc.Points.ReadConsistency readConsistency)
    Retrieves points.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.RetrievedPoint>>
    retrieveAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointId> ids, io.qdrant.client.grpc.Points.WithPayloadSelector payloadSelector, io.qdrant.client.grpc.Points.WithVectorsSelector vectorsSelector, io.qdrant.client.grpc.Points.ReadConsistency readConsistency, Duration timeout)
    Retrieves points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.ScrollResponse>
    scrollAsync(io.qdrant.client.grpc.Points.ScrollPoints request)
    Iterates over all or filtered points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.ScrollResponse>
    scrollAsync(io.qdrant.client.grpc.Points.ScrollPoints request, Duration timeout)
    Iterates over all or filtered points.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.ScoredPoint>>
    searchAsync(io.qdrant.client.grpc.Points.SearchPoints request)
    Retrieves closest points based on vector similarity and the given filtering conditions.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.ScoredPoint>>
    searchAsync(io.qdrant.client.grpc.Points.SearchPoints request, Duration timeout)
    Retrieves closest points based on vector similarity and the given filtering conditions.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.BatchResult>>
    searchBatchAsync(String collectionName, List<io.qdrant.client.grpc.Points.SearchPoints> searches, io.qdrant.client.grpc.Points.ReadConsistency readConsistency)
    Retrieves closest points based on vector similarity and the given filtering conditions.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.BatchResult>>
    searchBatchAsync(String collectionName, List<io.qdrant.client.grpc.Points.SearchPoints> searches, io.qdrant.client.grpc.Points.ReadConsistency readConsistency, Duration timeout)
    Retrieves closest points based on vector similarity and the given filtering conditions.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.PointGroup>>
    searchGroupsAsync(io.qdrant.client.grpc.Points.SearchPointGroups request)
    Retrieves closest points based on vector similarity and the given filtering conditions, grouped by a given field.
    com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.PointGroup>>
    searchGroupsAsync(io.qdrant.client.grpc.Points.SearchPointGroups request, Duration timeout)
    Retrieves closest points based on vector similarity and the given filtering conditions, grouped by a given field.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.SearchMatrixOffsets>
    searchMatrixOffsetsAsync(io.qdrant.client.grpc.Points.SearchMatrixPoints request)
    Compute distance matrix for sampled points with an offset based output format
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.SearchMatrixOffsets>
    searchMatrixOffsetsAsync(io.qdrant.client.grpc.Points.SearchMatrixPoints request, Duration timeout)
    Compute distance matrix for sampled points with an offset based output format
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.SearchMatrixPairs>
    searchMatrixPairsAsync(io.qdrant.client.grpc.Points.SearchMatrixPoints request)
    Compute distance matrix for sampled points with a pair based output format.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.SearchMatrixPairs>
    searchMatrixPairsAsync(io.qdrant.client.grpc.Points.SearchMatrixPoints request, Duration timeout)
    Compute distance matrix for sampled points with a pair based output format.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    setPayloadAsync(io.qdrant.client.grpc.Points.SetPayloadPoints request, Duration timeout)
    Sets the payload for the points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    setPayloadAsync(String collectionName, Map<String,io.qdrant.client.grpc.JsonWithInt.Value> payload, io.qdrant.client.grpc.Points.Filter filter, Boolean wait, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Sets the payload for the given ids.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    setPayloadAsync(String collectionName, Map<String,io.qdrant.client.grpc.JsonWithInt.Value> payload, io.qdrant.client.grpc.Points.PointId id, Boolean wait, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Sets the payload for the given id.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    setPayloadAsync(String collectionName, Map<String,io.qdrant.client.grpc.JsonWithInt.Value> payload, io.qdrant.client.grpc.Points.PointsSelector pointsSelector, Boolean wait, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Sets the payload for the points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    setPayloadAsync(String collectionName, Map<String,io.qdrant.client.grpc.JsonWithInt.Value> payload, io.qdrant.client.grpc.Points.PointsSelector pointsSelector, Boolean wait, String key, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Sets the payload for the points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    setPayloadAsync(String collectionName, Map<String,io.qdrant.client.grpc.JsonWithInt.Value> payload, Boolean wait, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Sets the payload for all points in the collection.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    setPayloadAsync(String collectionName, Map<String,io.qdrant.client.grpc.JsonWithInt.Value> payload, List<io.qdrant.client.grpc.Points.PointId> ids, Boolean wait, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Sets the payload for the given ids.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse>
    updateAliasesAsync(List<io.qdrant.client.grpc.Collections.AliasOperations> aliasOperations)
    Update the aliases of existing collections.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse>
    updateAliasesAsync(List<io.qdrant.client.grpc.Collections.AliasOperations> aliasOperations, Duration timeout)
    Update the aliases of existing collections.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse>
    updateCollectionAsync(io.qdrant.client.grpc.Collections.UpdateCollection updateCollection)
    Update parameters of the collection
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse>
    updateCollectionAsync(io.qdrant.client.grpc.Collections.UpdateCollection updateCollection, Duration timeout)
    Update parameters of the collection
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    updateVectorsAsync(io.qdrant.client.grpc.Points.UpdatePointVectors request, Duration timeout)
    Update named vectors for point.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    updateVectorsAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointVectors> points)
    Update named vectors for point.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    updateVectorsAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointVectors> points, Boolean wait, io.qdrant.client.grpc.Points.WriteOrderingType ordering, Duration timeout)
    Update named vectors for point.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    updateVectorsAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointVectors> points, Duration timeout)
    Update named vectors for point.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    upsertAsync(io.qdrant.client.grpc.Points.UpsertPoints request)
    Perform insert and updates on points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    upsertAsync(io.qdrant.client.grpc.Points.UpsertPoints request, Duration timeout)
    Perform insert and updates on points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    upsertAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointStruct> points)
    Perform insert and updates on points.
    com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult>
    upsertAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointStruct> points, Duration timeout)
    Perform insert and updates on points.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • QdrantClient

      public QdrantClient(QdrantGrpcClient grpcClient)
      Creates a new instance of QdrantClient
      Parameters:
      grpcClient - The low-level gRPC client to use.

  • Method Details

    • grpcClient

      public QdrantGrpcClient grpcClient()
      Gets the low-level gRPC client. This is exposed to
      • Allow access to the underlying gRPC channel
      • Allow access to the gRPC client to make requests using the low-level gRPC client in cases where functionality may not yet be exposed by the higher level client.
      Returns:
      The low-level gRPC client

    • healthCheckAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.QdrantOuterClass.HealthCheckReply> healthCheckAsync()
      Gets detailed information about the qdrant cluster.
      Returns:
      a new instance of ListenableFuture

    • healthCheckAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.QdrantOuterClass.HealthCheckReply> healthCheckAsync(@Nullable Duration timeout)
      Gets detailed information about the qdrant cluster.
      Parameters:
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • createCollectionAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse> createCollectionAsync(String collectionName, io.qdrant.client.grpc.Collections.VectorParams vectorParams)
      Creates a new collection with the given parameters
      Parameters:
      collectionName - The name of the collection.
      vectorParams - The vector parameters
      Returns:
      a new instance of ListenableFuture

    • createCollectionAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse> createCollectionAsync(String collectionName, io.qdrant.client.grpc.Collections.VectorParams vectorParams, @Nullable Duration timeout)
      Creates a new collection with the given parameters
      Parameters:
      collectionName - The name of the collection.
      vectorParams - The vector parameters
      timeout - The timeout for the call
      Returns:
      a new instance of ListenableFuture

    • createCollectionAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse> createCollectionAsync(String collectionName, Map<String,io.qdrant.client.grpc.Collections.VectorParams> namedVectorParams)
      Creates a new collection with the given parameters
      Parameters:
      collectionName - The name of the collection.
      namedVectorParams - The named vector parameters
      Returns:
      a new instance of ListenableFuture

    • createCollectionAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse> createCollectionAsync(String collectionName, Map<String,io.qdrant.client.grpc.Collections.VectorParams> namedVectorParams, @Nullable Duration timeout)
      Creates a new collection with the given parameters
      Parameters:
      collectionName - The name of the collection.
      namedVectorParams - The named vector parameters
      timeout - The timeout for the call
      Returns:
      a new instance of ListenableFuture

    • createCollectionAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse> createCollectionAsync(io.qdrant.client.grpc.Collections.CreateCollection createCollection)
      Creates a new collection with the given parameters
      Parameters:
      createCollection - The collection creation parameters
      Returns:
      a new instance of ListenableFuture

    • createCollectionAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse> createCollectionAsync(io.qdrant.client.grpc.Collections.CreateCollection createCollection, @Nullable Duration timeout)
      Creates a new collection with the given parameters
      Parameters:
      createCollection - The collection creation parameters
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • recreateCollectionAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse> recreateCollectionAsync(String collectionName, io.qdrant.client.grpc.Collections.VectorParams vectorParams)
      Deletes a collection if one exists, and creates a new collection with the given parameters.
      Parameters:
      collectionName - The name of the collection.
      vectorParams - The vector parameters
      Returns:
      a new instance of ListenableFuture

    • recreateCollectionAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse> recreateCollectionAsync(String collectionName, io.qdrant.client.grpc.Collections.VectorParams vectorParams, @Nullable Duration timeout)
      Deletes a collection if one exists, and creates a new collection with the given parameters.
      Parameters:
      collectionName - The name of the collection.
      vectorParams - The vector parameters
      timeout - The timeout for the call
      Returns:
      a new instance of ListenableFuture

    • recreateCollectionAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse> recreateCollectionAsync(String collectionName, Map<String,io.qdrant.client.grpc.Collections.VectorParams> namedVectorParams)
      Deletes a collection if one exists, and creates a new collection with the given parameters.
      Parameters:
      collectionName - The name of the collection.
      namedVectorParams - The named vector parameters
      Returns:
      a new instance of ListenableFuture

    • recreateCollectionAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse> recreateCollectionAsync(String collectionName, Map<String,io.qdrant.client.grpc.Collections.VectorParams> namedVectorParams, @Nullable Duration timeout)
      Deletes a collection if one exists, and creates a new collection with the given parameters.
      Parameters:
      collectionName - The name of the collection.
      namedVectorParams - The named vector parameters
      timeout - The timeout for the call
      Returns:
      a new instance of ListenableFuture

    • recreateCollectionAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse> recreateCollectionAsync(io.qdrant.client.grpc.Collections.CreateCollection createCollection)
      Deletes a collection if one exists, and creates a new collection with the given parameters.
      Parameters:
      createCollection - The collection creation parameters
      Returns:
      a new instance of Collections.CollectionOperationResponse

    • recreateCollectionAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse> recreateCollectionAsync(io.qdrant.client.grpc.Collections.CreateCollection createCollection, @Nullable Duration timeout)
      Deletes a collection if one exists, and creates a new collection with the given parameters.
      Parameters:
      createCollection - The collection creation parameters
      timeout - The timeout for the call.
      Returns:
      a new instance of Collections.CollectionOperationResponse

    • getCollectionInfoAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionInfo> getCollectionInfoAsync(String collectionName)
      Gets detailed information about an existing collection.
      Parameters:
      collectionName - The name of the collection.
      Returns:
      a new instance of ListenableFuture

    • getCollectionInfoAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionInfo> getCollectionInfoAsync(String collectionName, @Nullable Duration timeout)
      Gets detailed information about an existing collection.
      Parameters:
      collectionName - The name of the collection.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • deleteCollectionAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse> deleteCollectionAsync(String collectionName)
      Deletes a collection and all its associated data.
      Parameters:
      collectionName - The name of the collection
      Returns:
      a new instance of ListenableFuture

    • deleteCollectionAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse> deleteCollectionAsync(String collectionName, @Nullable Duration timeout)
      Deletes a collection and all its associated data.
      Parameters:
      collectionName - The name of the collection
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • listCollectionsAsync

      public com.google.common.util.concurrent.ListenableFuture<List<String>> listCollectionsAsync()
      Gets the names of all existing collections
      Returns:
      a new instance of ListenableFuture

    • listCollectionsAsync

      public com.google.common.util.concurrent.ListenableFuture<List<String>> listCollectionsAsync(@Nullable Duration timeout)
      Gets the names of all existing collections
      Parameters:
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • updateCollectionAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse> updateCollectionAsync(io.qdrant.client.grpc.Collections.UpdateCollection updateCollection)
      Update parameters of the collection
      Parameters:
      updateCollection - The update parameters.
      Returns:
      a new instance of ListenableFuture

    • updateCollectionAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse> updateCollectionAsync(io.qdrant.client.grpc.Collections.UpdateCollection updateCollection, @Nullable Duration timeout)
      Update parameters of the collection
      Parameters:
      updateCollection - The update parameters.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • collectionExistsAsync

      public com.google.common.util.concurrent.ListenableFuture<Boolean> collectionExistsAsync(String collectionName)
      Check if a collection exists
      Parameters:
      collectionName - The name of the collection.
      Returns:
      a new instance of ListenableFuture

    • collectionExistsAsync

      public com.google.common.util.concurrent.ListenableFuture<Boolean> collectionExistsAsync(String collectionName, @Nullable Duration timeout)
      Check if a collection exists
      Parameters:
      collectionName - The name of the collection.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • createAliasAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse> createAliasAsync(String aliasName, String collectionName)
      Creates an alias for a given collection.
      Parameters:
      aliasName - The alias to be created.
      collectionName - The collection for which the alias is to be created.
      Returns:
      a new instance of ListenableFuture

    • createAliasAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse> createAliasAsync(String aliasName, String collectionName, @Nullable Duration timeout)
      Creates an alias for a given collection.
      Parameters:
      aliasName - The alias to be created.
      collectionName - The collection for which the alias is to be created.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • renameAliasAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse> renameAliasAsync(String oldAliasName, String newAliasName)
      Renames an existing alias.
      Parameters:
      oldAliasName - The old alias name.
      newAliasName - The new alias name.
      Returns:
      a new instance of ListenableFuture

    • renameAliasAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse> renameAliasAsync(String oldAliasName, String newAliasName, @Nullable Duration timeout)
      Renames an existing alias.
      Parameters:
      oldAliasName - The old alias name.
      newAliasName - The new alias name.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • deleteAliasAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse> deleteAliasAsync(String aliasName)
      Deletes an alias.
      Parameters:
      aliasName - The alias to be deleted.
      Returns:
      a new instance of ListenableFuture

    • deleteAliasAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse> deleteAliasAsync(String aliasName, @Nullable Duration timeout)
      Deletes an alias.
      Parameters:
      aliasName - The alias to be deleted.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • updateAliasesAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse> updateAliasesAsync(List<io.qdrant.client.grpc.Collections.AliasOperations> aliasOperations)
      Update the aliases of existing collections.
      Parameters:
      aliasOperations - The list of operations to perform.
      Returns:
      a new instance of ListenableFuture

    • updateAliasesAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CollectionOperationResponse> updateAliasesAsync(List<io.qdrant.client.grpc.Collections.AliasOperations> aliasOperations, @Nullable Duration timeout)
      Update the aliases of existing collections.
      Parameters:
      aliasOperations - The list of operations to perform.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • listCollectionAliasesAsync

      public com.google.common.util.concurrent.ListenableFuture<List<String>> listCollectionAliasesAsync(String collectionName)
      Gets a list of all aliases for a collection.
      Parameters:
      collectionName - The name of the collection.
      Returns:
      a new instance of ListenableFuture

    • listCollectionAliasesAsync

      public com.google.common.util.concurrent.ListenableFuture<List<String>> listCollectionAliasesAsync(String collectionName, @Nullable Duration timeout)
      Gets a list of all aliases for a collection.
      Parameters:
      collectionName - The name of the collection.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • listAliasesAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Collections.AliasDescription>> listAliasesAsync()
      Gets a list of all aliases for all existing collections.
      Returns:
      a new instance of ListenableFuture

    • listAliasesAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Collections.AliasDescription>> listAliasesAsync(@Nullable Duration timeout)
      Gets a list of all aliases for all existing collections.
      Parameters:
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • createShardKeyAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CreateShardKeyResponse> createShardKeyAsync(io.qdrant.client.grpc.Collections.CreateShardKeyRequest createShardKey)
      Creates a shard key for a collection.
      Parameters:
      createShardKey - The request object for the operation.
      Returns:
      a new instance of ListenableFuture

    • createShardKeyAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.CreateShardKeyResponse> createShardKeyAsync(io.qdrant.client.grpc.Collections.CreateShardKeyRequest createShardKey, @Nullable Duration timeout)
      Creates a shard key for a collection.
      Parameters:
      createShardKey - The request object for the operation.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • deleteShardKeyAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.DeleteShardKeyResponse> deleteShardKeyAsync(io.qdrant.client.grpc.Collections.DeleteShardKeyRequest deleteShardKey)
      Deletes a shard key for a collection.
      Parameters:
      deleteShardKey - The request object for the operation.
      Returns:
      a new instance of ListenableFuture

    • deleteShardKeyAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Collections.DeleteShardKeyResponse> deleteShardKeyAsync(io.qdrant.client.grpc.Collections.DeleteShardKeyRequest deleteShardKey, @Nullable Duration timeout)
      Deletes a shard key for a collection.
      Parameters:
      deleteShardKey - The request object for the operation.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • upsertAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> upsertAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointStruct> points)
      Perform insert and updates on points. If a point with a given ID already exists, it will be overwritten.
      Parameters:
      collectionName - The name of the collection.
      points - The points to be upserted
      Returns:
      a new instance of ListenableFuture

    • upsertAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> upsertAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointStruct> points, @Nullable Duration timeout)
      Perform insert and updates on points. If a point with a given ID already exists, it will be overwritten. The call waits for the changes to be applied.
      Parameters:
      collectionName - The name of the collection.
      points - The points to be upserted
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • upsertAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> upsertAsync(io.qdrant.client.grpc.Points.UpsertPoints request)
      Perform insert and updates on points. If a point with a given ID already exists, it will be overwritten.
      Parameters:
      request - The upsert points request
      Returns:
      a new instance of ListenableFuture

    • upsertAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> upsertAsync(io.qdrant.client.grpc.Points.UpsertPoints request, @Nullable Duration timeout)
      Perform insert and updates on points. If a point with a given ID already exists, it will be overwritten.
      Parameters:
      request - The upsert points request
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • deleteAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> deleteAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointId> ids)
      Deletes points. The call waits for the changes to be applied.
      Parameters:
      collectionName - The name of the collection.
      ids - The ids of points to delete.
      Returns:
      a new instance of ListenableFuture

    • deleteAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> deleteAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointId> ids, @Nullable Duration timeout)
      Deletes points. The call waits for the changes to be applied.
      Parameters:
      collectionName - The name of the collection.
      ids - The ids of points to delete.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • deleteAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> deleteAsync(String collectionName, io.qdrant.client.grpc.Points.Filter filter)
      Deletes points. The call waits for the changes to be applied.
      Parameters:
      collectionName - The name of the collection.
      filter - A filter selecting the points to be deleted.
      Returns:
      a new instance of ListenableFuture

    • deleteAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> deleteAsync(String collectionName, io.qdrant.client.grpc.Points.Filter filter, @Nullable Duration timeout)
      Deletes points.
      Parameters:
      collectionName - The name of the collection.
      filter - A filter selecting the points to be deleted.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • deleteAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> deleteAsync(io.qdrant.client.grpc.Points.DeletePoints request)
      Deletes points.
      Parameters:
      request - The delete points request
      Returns:
      a new instance of ListenableFuture

    • deleteAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> deleteAsync(io.qdrant.client.grpc.Points.DeletePoints request, @Nullable Duration timeout)
      Deletes points.
      Parameters:
      request - The delete points request
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • retrieveAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.RetrievedPoint>> retrieveAsync(String collectionName, io.qdrant.client.grpc.Points.PointId id, @Nullable io.qdrant.client.grpc.Points.ReadConsistency readConsistency)
      Retrieves points. Includes all payload, excludes vectors.
      Parameters:
      collectionName - The name of the collection.
      id - The id of a point to retrieve
      readConsistency - Options for specifying read consistency guarantees.
      Returns:
      a new instance of ListenableFuture

    • retrieveAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.RetrievedPoint>> retrieveAsync(String collectionName, io.qdrant.client.grpc.Points.PointId id, boolean withPayload, boolean withVectors, @Nullable io.qdrant.client.grpc.Points.ReadConsistency readConsistency)
      Retrieves points.
      Parameters:
      collectionName - The name of the collection.
      id - The id of a point to retrieve
      withPayload - Whether to include the payload or not.
      withVectors - Whether to include the vectors or not.
      readConsistency - Options for specifying read consistency guarantees.
      Returns:
      a new instance of ListenableFuture

    • retrieveAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.RetrievedPoint>> retrieveAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointId> ids, @Nullable io.qdrant.client.grpc.Points.ReadConsistency readConsistency)
      Retrieves points. Includes all payload, excludes vectors.
      Parameters:
      collectionName - The name of the collection.
      ids - The list of ids of points to retrieve
      readConsistency - Options for specifying read consistency guarantees.
      Returns:
      a new instance of ListenableFuture

    • retrieveAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.RetrievedPoint>> retrieveAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointId> ids, boolean withPayload, boolean withVectors, @Nullable io.qdrant.client.grpc.Points.ReadConsistency readConsistency)
      Retrieves points.
      Parameters:
      collectionName - The name of the collection.
      ids - The list of ids of points to retrieve
      withPayload - Whether to include the payload or not.
      withVectors - Whether to include the vectors or not.
      readConsistency - Options for specifying read consistency guarantees.
      Returns:
      a new instance of ListenableFuture

    • retrieveAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.RetrievedPoint>> retrieveAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointId> ids, io.qdrant.client.grpc.Points.WithPayloadSelector payloadSelector, io.qdrant.client.grpc.Points.WithVectorsSelector vectorsSelector, @Nullable io.qdrant.client.grpc.Points.ReadConsistency readConsistency)
      Retrieves points.
      Parameters:
      collectionName - The name of the collection.
      ids - The list of ids of points to retrieve
      payloadSelector - Options for specifying which payload to include or not.
      vectorsSelector - Options for specifying which vectors to include into response.
      readConsistency - Options for specifying read consistency guarantees.
      Returns:
      a new instance of ListenableFuture

    • retrieveAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.RetrievedPoint>> retrieveAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointId> ids, io.qdrant.client.grpc.Points.WithPayloadSelector payloadSelector, io.qdrant.client.grpc.Points.WithVectorsSelector vectorsSelector, @Nullable io.qdrant.client.grpc.Points.ReadConsistency readConsistency, @Nullable Duration timeout)
      Retrieves points.
      Parameters:
      collectionName - The name of the collection.
      ids - The list of ids of points to retrieve
      payloadSelector - Options for specifying which payload to include or not.
      vectorsSelector - Options for specifying which vectors to include into response.
      readConsistency - Options for specifying read consistency guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • retrieveAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.RetrievedPoint>> retrieveAsync(io.qdrant.client.grpc.Points.GetPoints request, @Nullable Duration timeout)
      Retrieves points.
      Parameters:
      request - The get points request
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • updateVectorsAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> updateVectorsAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointVectors> points)
      Update named vectors for point.
      Parameters:
      collectionName - The name of the collection.
      points - The list of points and vectors to update.
      Returns:
      a new instance of ListenableFuture

    • updateVectorsAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> updateVectorsAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointVectors> points, @Nullable Duration timeout)
      Update named vectors for point.
      Parameters:
      collectionName - The name of the collection.
      points - The list of points and vectors to update.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • updateVectorsAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> updateVectorsAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointVectors> points, @Nullable Boolean wait, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Update named vectors for point.
      Parameters:
      collectionName - The name of the collection.
      points - The list of points and vectors to update.
      wait - Whether to wait until the changes have been applied. Defaults to true.
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • updateVectorsAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> updateVectorsAsync(io.qdrant.client.grpc.Points.UpdatePointVectors request, @Nullable Duration timeout)
      Update named vectors for point.
      Parameters:
      request - The update point vectors request
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • deleteVectorsAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> deleteVectorsAsync(String collectionName, List<String> vectors, io.qdrant.client.grpc.Points.Filter filter)
      Delete named vectors for points.
      Parameters:
      collectionName - The name of the collection.
      vectors - The list of vector names to delete.
      filter - A filter selecting the points to be deleted.
      Returns:
      a new instance of ListenableFuture

    • deleteVectorsAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> deleteVectorsAsync(String collectionName, List<String> vectors, io.qdrant.client.grpc.Points.Filter filter, @Nullable Duration timeout)
      Delete named vectors for points.
      Parameters:
      collectionName - The name of the collection.
      vectors - The list of vector names to delete.
      filter - A filter selecting the points to be deleted.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • deleteVectorsAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> deleteVectorsAsync(String collectionName, List<String> vectors, io.qdrant.client.grpc.Points.Filter filter, @Nullable Boolean wait, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Delete named vectors for points.
      Parameters:
      collectionName - The name of the collection.
      vectors - The list of vector names to delete.
      filter - A filter selecting the points to be deleted.
      wait - Whether to wait until the changes have been applied. Defaults to true.
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • deleteVectorsAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> deleteVectorsAsync(String collectionName, List<String> vectors, List<io.qdrant.client.grpc.Points.PointId> ids)
      Delete named vectors for points.
      Parameters:
      collectionName - The name of the collection.
      vectors - The list of vector names to delete.
      ids - The list of ids to delete.
      Returns:
      a new instance of ListenableFuture

    • deleteVectorsAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> deleteVectorsAsync(String collectionName, List<String> vectors, List<io.qdrant.client.grpc.Points.PointId> ids, @Nullable Duration timeout)
      Delete named vectors for points.
      Parameters:
      collectionName - The name of the collection.
      vectors - The list of vector names to delete.
      ids - The list of ids to delete.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • deleteVectorsAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> deleteVectorsAsync(String collectionName, List<String> vectors, List<io.qdrant.client.grpc.Points.PointId> ids, @Nullable Boolean wait, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Delete named vectors for points.
      Parameters:
      collectionName - The name of the collection.
      vectors - The list of vector names to delete.
      ids - The list of ids to delete.
      wait - Whether to wait until the changes have been applied. Defaults to true.
      ordering - Write ordering guarantees.
      timeout - The timeout for the call
      Returns:
      a new instance of ListenableFuture

    • deleteVectorsAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> deleteVectorsAsync(String collectionName, List<String> vectors, io.qdrant.client.grpc.Points.PointsSelector pointsSelector, @Nullable Boolean wait, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Delete named vectors for points.
      Parameters:
      collectionName - The name of the collection.
      vectors - The list of vector names to delete.
      pointsSelector - A selector for the points to be deleted.
      wait - Whether to wait until the changes have been applied. Defaults to true.
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • deleteVectorsAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> deleteVectorsAsync(io.qdrant.client.grpc.Points.DeletePointVectors request, @Nullable Duration timeout)
      Delete named vectors for points.
      Parameters:
      request - The delete point vectors request
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • setPayloadAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> setPayloadAsync(String collectionName, Map<String,io.qdrant.client.grpc.JsonWithInt.Value> payload, @Nullable Boolean wait, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Sets the payload for all points in the collection.
      Parameters:
      collectionName - The name of the collection.
      payload - New payload values
      wait - Whether to wait until the changes have been applied. Defaults to true.
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • setPayloadAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> setPayloadAsync(String collectionName, Map<String,io.qdrant.client.grpc.JsonWithInt.Value> payload, io.qdrant.client.grpc.Points.PointId id, @Nullable Boolean wait, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Sets the payload for the given id.
      Parameters:
      collectionName - The name of the collection.
      payload - New payload values
      id - The id for which to set the payload.
      wait - Whether to wait until the changes have been applied. Defaults to true.
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • setPayloadAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> setPayloadAsync(String collectionName, Map<String,io.qdrant.client.grpc.JsonWithInt.Value> payload, List<io.qdrant.client.grpc.Points.PointId> ids, @Nullable Boolean wait, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Sets the payload for the given ids.
      Parameters:
      collectionName - The name of the collection.
      payload - New payload values
      ids - The ids for which to set the payload.
      wait - Whether to wait until the changes have been applied. Defaults to true.
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • setPayloadAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> setPayloadAsync(String collectionName, Map<String,io.qdrant.client.grpc.JsonWithInt.Value> payload, io.qdrant.client.grpc.Points.Filter filter, @Nullable Boolean wait, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Sets the payload for the given ids.
      Parameters:
      collectionName - The name of the collection.
      payload - New payload values
      filter - A filter selecting the points to be set.
      wait - Whether to wait until the changes have been applied. Defaults to true.
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • setPayloadAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> setPayloadAsync(String collectionName, Map<String,io.qdrant.client.grpc.JsonWithInt.Value> payload, @Nullable io.qdrant.client.grpc.Points.PointsSelector pointsSelector, @Nullable Boolean wait, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Sets the payload for the points.
      Parameters:
      collectionName - The name of the collection.
      payload - New payload values
      pointsSelector - selector for the points whose payloads are to be set.
      wait - Whether to wait until the changes have been applied. Defaults to true.
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • setPayloadAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> setPayloadAsync(String collectionName, Map<String,io.qdrant.client.grpc.JsonWithInt.Value> payload, @Nullable io.qdrant.client.grpc.Points.PointsSelector pointsSelector, @Nullable Boolean wait, @Nullable String key, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Sets the payload for the points.
      Parameters:
      collectionName - The name of the collection.
      payload - New payload values
      pointsSelector - Selector for the points whose payloads are to be set.
      wait - Whether to wait until the changes have been applied. Defaults to true.
      key - The key for which to set the payload if nested
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • setPayloadAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> setPayloadAsync(io.qdrant.client.grpc.Points.SetPayloadPoints request, @Nullable Duration timeout)
      Sets the payload for the points.
      Parameters:
      request - The set payload request.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • overwritePayloadAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> overwritePayloadAsync(String collectionName, Map<String,io.qdrant.client.grpc.JsonWithInt.Value> payload, @Nullable Boolean wait, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Overwrites the payload for all points in the collection.
      Parameters:
      collectionName - The name of the collection.
      payload - New payload values
      wait - Whether to wait until the changes have been applied. Defaults to true.
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • overwritePayloadAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> overwritePayloadAsync(String collectionName, Map<String,io.qdrant.client.grpc.JsonWithInt.Value> payload, io.qdrant.client.grpc.Points.PointId id, @Nullable Boolean wait, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Overwrites the payload for the given id.
      Parameters:
      collectionName - The name of the collection.
      payload - New payload values
      id - The id for which to overwrite the payload.
      wait - Whether to wait until the changes have been applied. Defaults to true.
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • overwritePayloadAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> overwritePayloadAsync(String collectionName, Map<String,io.qdrant.client.grpc.JsonWithInt.Value> payload, List<io.qdrant.client.grpc.Points.PointId> ids, @Nullable Boolean wait, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Overwrites the payload for the given ids.
      Parameters:
      collectionName - The name of the collection.
      payload - New payload values
      ids - The ids for which to overwrite the payload.
      wait - Whether to wait until the changes have been applied. Defaults to true.
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • overwritePayloadAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> overwritePayloadAsync(String collectionName, Map<String,io.qdrant.client.grpc.JsonWithInt.Value> payload, io.qdrant.client.grpc.Points.Filter filter, @Nullable Boolean wait, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Overwrites the payload for the filtered points.
      Parameters:
      collectionName - The name of the collection.
      payload - New payload values
      filter - A filter selecting the points for which to overwrite the payload.
      wait - Whether to wait until the changes have been applied. Defaults to true.
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • overwritePayloadAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> overwritePayloadAsync(String collectionName, Map<String,io.qdrant.client.grpc.JsonWithInt.Value> payload, @Nullable io.qdrant.client.grpc.Points.PointsSelector pointsSelector, @Nullable Boolean wait, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Overwrites the payload for the points.
      Parameters:
      collectionName - The name of the collection.
      payload - New payload values
      pointsSelector - A selector for the points whose payloads are to be overwritten.
      wait - Whether to wait until the changes have been applied. Defaults to true.
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • overwritePayloadAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> overwritePayloadAsync(String collectionName, Map<String,io.qdrant.client.grpc.JsonWithInt.Value> payload, @Nullable io.qdrant.client.grpc.Points.PointsSelector pointsSelector, @Nullable Boolean wait, @Nullable String key, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Overwrites the payload for the points.
      Parameters:
      collectionName - The name of the collection.
      payload - New payload values
      pointsSelector - Selector for the points whose payloads are to be overwritten.
      wait - Whether to wait until the changes have been applied. Defaults to true.
      key - The key for which to overwrite the payload if nested
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • overwritePayloadAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> overwritePayloadAsync(io.qdrant.client.grpc.Points.SetPayloadPoints request, @Nullable Duration timeout)
      Overwrites the payload for the points.
      Parameters:
      request - The overwrite payload request
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • deletePayloadAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> deletePayloadAsync(String collectionName, List<String> keys, @Nullable Boolean wait, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Delete specified key payload for all points.
      Parameters:
      collectionName - The name of the collection.
      keys - List of keys to delete.
      wait - Whether to wait until the changes have been applied. Defaults to true.
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • deletePayloadAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> deletePayloadAsync(String collectionName, List<String> keys, io.qdrant.client.grpc.Points.PointId id, @Nullable Boolean wait, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Delete specified key payload for the given id.
      Parameters:
      collectionName - The name of the collection.
      keys - List of keys to delete.
      id - The id for which to delete the payload.
      wait - Whether to wait until the changes have been applied. Defaults to true.
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • deletePayloadAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> deletePayloadAsync(String collectionName, List<String> keys, List<io.qdrant.client.grpc.Points.PointId> ids, @Nullable Boolean wait, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Delete specified key payload for the given ids.
      Parameters:
      collectionName - The name of the collection.
      keys - List of keys to delete.
      ids - The ids for which to delete the payload.
      wait - Whether to wait until the changes have been applied. Defaults to true.
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • deletePayloadAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> deletePayloadAsync(String collectionName, List<String> keys, io.qdrant.client.grpc.Points.Filter filter, @Nullable Boolean wait, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Delete specified key payload for the filtered points.
      Parameters:
      collectionName - The name of the collection.
      keys - List of keys to delete.
      filter - A filter selecting the points to for which to delete the payload.
      wait - Whether to wait until the changes have been applied. Defaults to true.
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • deletePayloadAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> deletePayloadAsync(String collectionName, List<String> keys, @Nullable io.qdrant.client.grpc.Points.PointsSelector pointsSelector, @Nullable Boolean wait, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Delete specified key payload for the points.
      Parameters:
      collectionName - The name of the collection.
      keys - List of keys to delete.
      pointsSelector - selector for the points whose payloads are to be deleted.
      wait - Whether to wait until the changes have been applied. Defaults to true.
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • deletePayloadAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> deletePayloadAsync(io.qdrant.client.grpc.Points.DeletePayloadPoints request, @Nullable Duration timeout)
      Delete specified key payload for the points.
      Parameters:
      request - The delete payload request
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • clearPayloadAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> clearPayloadAsync(String collectionName, @Nullable Boolean wait, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Remove all payload for all points.
      Parameters:
      collectionName - The name of the collection.
      wait - Whether to wait until the changes have been applied. Defaults to true.
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • clearPayloadAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> clearPayloadAsync(String collectionName, io.qdrant.client.grpc.Points.PointId id, @Nullable Boolean wait, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Removes all payload for the given id.
      Parameters:
      collectionName - The name of the collection.
      id - The id for which to remove the payload.
      wait - Whether to wait until the changes have been applied. Defaults to true.
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • clearPayloadAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> clearPayloadAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointId> ids, @Nullable Boolean wait, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Removes all payload for the given ids.
      Parameters:
      collectionName - The name of the collection.
      ids - The ids for which to remove the payload.
      wait - Whether to wait until the changes have been applied. Defaults to true.
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • clearPayloadAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> clearPayloadAsync(String collectionName, io.qdrant.client.grpc.Points.Filter filter, @Nullable Boolean wait, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Removes all payload for the filtered points.
      Parameters:
      collectionName - The name of the collection.
      filter - A filter selecting the points for which to remove the payload.
      wait - Whether to wait until the changes have been applied. Defaults to true.
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • clearPayloadAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> clearPayloadAsync(String collectionName, @Nullable io.qdrant.client.grpc.Points.PointsSelector pointsSelector, @Nullable Boolean wait, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Removes all payload for the points.
      Parameters:
      collectionName - The name of the collection.
      pointsSelector - A selector for the points whose payloads are to be removed.
      wait - Whether to wait until the changes have been applied. Defaults to true.
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • clearPayloadAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> clearPayloadAsync(io.qdrant.client.grpc.Points.ClearPayloadPoints request, @Nullable Duration timeout)
      Removes all payload for the points.
      Parameters:
      request - The clear payload request
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • createPayloadIndexAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> createPayloadIndexAsync(String collectionName, String field, io.qdrant.client.grpc.Collections.PayloadSchemaType schemaType, @Nullable io.qdrant.client.grpc.Collections.PayloadIndexParams indexParams, @Nullable Boolean wait, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Creates a payload field index in a collection.
      Parameters:
      collectionName - The name of the collection.
      field - The field name to index.
      schemaType - The schema type of the field.
      indexParams - Payload index parameters.
      wait - Whether to wait until the changes have been applied. Defaults to true.
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • createPayloadIndexAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> createPayloadIndexAsync(io.qdrant.client.grpc.Points.CreateFieldIndexCollection request, @Nullable Duration timeout)
      Creates a payload field index in a collection.
      Parameters:
      request - The create field index request.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • deletePayloadIndexAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.UpdateResult> deletePayloadIndexAsync(String collectionName, String field, @Nullable Boolean wait, @Nullable io.qdrant.client.grpc.Points.WriteOrderingType ordering, @Nullable Duration timeout)
      Deletes a payload field index in a collection.
      Parameters:
      collectionName - The name of the collection.
      field - The field name to index.
      wait - Whether to wait until the changes have been applied. Defaults to true.
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • searchAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.ScoredPoint>> searchAsync(io.qdrant.client.grpc.Points.SearchPoints request)
      Retrieves closest points based on vector similarity and the given filtering conditions.
      Parameters:
      request - the search request
      Returns:
      a new instance of ListenableFuture

    • searchAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.ScoredPoint>> searchAsync(io.qdrant.client.grpc.Points.SearchPoints request, @Nullable Duration timeout)
      Retrieves closest points based on vector similarity and the given filtering conditions.
      Parameters:
      request - the search request
      timeout - the timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • searchBatchAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.BatchResult>> searchBatchAsync(String collectionName, List<io.qdrant.client.grpc.Points.SearchPoints> searches, @Nullable io.qdrant.client.grpc.Points.ReadConsistency readConsistency)
      Retrieves closest points based on vector similarity and the given filtering conditions.
      Parameters:
      collectionName - The name of the collection
      searches - The searches to be performed in the batch.
      readConsistency - Options for specifying read consistency guarantees.
      Returns:
      a new instance of ListenableFuture

    • searchBatchAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.BatchResult>> searchBatchAsync(String collectionName, List<io.qdrant.client.grpc.Points.SearchPoints> searches, @Nullable io.qdrant.client.grpc.Points.ReadConsistency readConsistency, @Nullable Duration timeout)
      Retrieves closest points based on vector similarity and the given filtering conditions.
      Parameters:
      collectionName - The name of the collection
      searches - The searches to be performed in the batch.
      readConsistency - Options for specifying read consistency guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • searchGroupsAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.PointGroup>> searchGroupsAsync(io.qdrant.client.grpc.Points.SearchPointGroups request)
      Retrieves closest points based on vector similarity and the given filtering conditions, grouped by a given field.
      Parameters:
      request - The search group request
      Returns:
      a new instance of ListenableFuture

    • searchGroupsAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.PointGroup>> searchGroupsAsync(io.qdrant.client.grpc.Points.SearchPointGroups request, @Nullable Duration timeout)
      Retrieves closest points based on vector similarity and the given filtering conditions, grouped by a given field.
      Parameters:
      request - The search group request
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • scrollAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.ScrollResponse> scrollAsync(io.qdrant.client.grpc.Points.ScrollPoints request)
      Iterates over all or filtered points.
      Parameters:
      request - The scroll request
      Returns:
      a new instance of ListenableFuture

    • scrollAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.ScrollResponse> scrollAsync(io.qdrant.client.grpc.Points.ScrollPoints request, @Nullable Duration timeout)
      Iterates over all or filtered points.
      Parameters:
      request - The scroll request.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • recommendAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.ScoredPoint>> recommendAsync(io.qdrant.client.grpc.Points.RecommendPoints request)
      Look for the points which are closer to stored positive examples and at the same time further to negative examples.
      Parameters:
      request - The recommend request
      Returns:
      a new instance of ListenableFuture

    • recommendAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.ScoredPoint>> recommendAsync(io.qdrant.client.grpc.Points.RecommendPoints request, @Nullable Duration timeout)
      Look for the points which are closer to stored positive examples and at the same time further to negative examples.
      Parameters:
      request - The recommend request.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • recommendBatchAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.BatchResult>> recommendBatchAsync(String collectionName, List<io.qdrant.client.grpc.Points.RecommendPoints> recommendSearches, @Nullable io.qdrant.client.grpc.Points.ReadConsistency readConsistency)
      Look for the points which are closer to stored positive examples and at the same time further to negative examples.
      Parameters:
      collectionName - The name of the collection.
      recommendSearches - The list of recommendation searches.
      readConsistency - Options for specifying read consistency guarantees.
      Returns:
      a new instance of ListenableFuture

    • recommendBatchAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.BatchResult>> recommendBatchAsync(String collectionName, List<io.qdrant.client.grpc.Points.RecommendPoints> recommendSearches, @Nullable io.qdrant.client.grpc.Points.ReadConsistency readConsistency, @Nullable Duration timeout)
      Look for the points which are closer to stored positive examples and at the same time further to negative examples.
      Parameters:
      collectionName - The name of the collection.
      recommendSearches - The list of recommendation searches.
      readConsistency - Options for specifying read consistency guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • batchUpdateAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.UpdateResult>> batchUpdateAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointsUpdateOperation> operations)
      Performs a batch update of points.
      Parameters:
      collectionName - The name of the collection.
      operations - The list of point update operations.
      Returns:
      a new instance of ListenableFuture

    • batchUpdateAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.UpdateResult>> batchUpdateAsync(String collectionName, List<io.qdrant.client.grpc.Points.PointsUpdateOperation> operations, @Nullable Boolean wait, @Nullable io.qdrant.client.grpc.Points.WriteOrdering ordering, @Nullable Duration timeout)
      Performs a batch update of points.
      Parameters:
      collectionName - The name of the collection.
      operations - The list of point update operations.
      wait - Whether to wait until the changes have been applied. Defaults to true.
      ordering - Write ordering guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • batchUpdateAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.UpdateResult>> batchUpdateAsync(io.qdrant.client.grpc.Points.UpdateBatchPoints request, @Nullable Duration timeout)
      Performs a batch update of points.
      Parameters:
      request - The update batch request.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • recommendGroupsAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.PointGroup>> recommendGroupsAsync(io.qdrant.client.grpc.Points.RecommendPointGroups request)
      Look for the points which are closer to stored positive examples and at the same time further to negative examples, grouped by a given field
      Parameters:
      request - The recommend groups request
      Returns:
      a new instance of ListenableFuture

    • recommendGroupsAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.PointGroup>> recommendGroupsAsync(io.qdrant.client.grpc.Points.RecommendPointGroups request, @Nullable Duration timeout)
      Look for the points which are closer to stored positive examples and at the same time further to negative examples, grouped by a given field
      Parameters:
      request - The recommend groups request
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • discoverAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.ScoredPoint>> discoverAsync(io.qdrant.client.grpc.Points.DiscoverPoints request)
      Use the context and a target to find the most similar points to the target. Constraints by the context.
      Parameters:
      request - The discover points request
      Returns:
      a new instance of ListenableFuture

    • discoverAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.ScoredPoint>> discoverAsync(io.qdrant.client.grpc.Points.DiscoverPoints request, @Nullable Duration timeout)
      Use the context and a target to find the most similar points to the target. Constraints by the context.
      Parameters:
      request - The discover points request
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • discoverBatchAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.BatchResult>> discoverBatchAsync(String collectionName, List<io.qdrant.client.grpc.Points.DiscoverPoints> discoverSearches, @Nullable io.qdrant.client.grpc.Points.ReadConsistency readConsistency)
      Use the context and a target to find the most similar points to the target in a batch. Constrained by the context.
      Parameters:
      collectionName - The name of the collection
      discoverSearches - The list for discover point searches
      readConsistency - Options for specifying read consistency guarantees
      Returns:
      a new instance of ListenableFuture

    • discoverBatchAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.BatchResult>> discoverBatchAsync(String collectionName, List<io.qdrant.client.grpc.Points.DiscoverPoints> discoverSearches, @Nullable io.qdrant.client.grpc.Points.ReadConsistency readConsistency, @Nullable Duration timeout)
      Use the context and a target to find the most similar points to the target in a batch. Constrained by the context.
      Parameters:
      collectionName - The name of the collection
      discoverSearches - The list for discover point searches
      readConsistency - Options for specifying read consistency guarantees
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • countAsync

      public com.google.common.util.concurrent.ListenableFuture<Long> countAsync(String collectionName)
      Count the points in a collection. The count is exact
      Parameters:
      collectionName - The name of the collection.
      Returns:
      a new instance of ListenableFuture

    • countAsync

      public com.google.common.util.concurrent.ListenableFuture<Long> countAsync(String collectionName, @Nullable Duration timeout)
      Count the points in a collection. The count is exact
      Parameters:
      collectionName - The name of the collection.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • countAsync

      public com.google.common.util.concurrent.ListenableFuture<Long> countAsync(String collectionName, @Nullable io.qdrant.client.grpc.Points.Filter filter, @Nullable Boolean exact)
      Count the points in a collection with the given filtering conditions.
      Parameters:
      collectionName - The name of the collection.
      filter - Filter conditions - return only those points that satisfy the specified conditions.
      exact - If true, returns the exact count, if false, returns an approximate count. Defaults to true.
      Returns:
      a new instance of ListenableFuture

    • countAsync

      public com.google.common.util.concurrent.ListenableFuture<Long> countAsync(String collectionName, @Nullable io.qdrant.client.grpc.Points.Filter filter, @Nullable Boolean exact, @Nullable Duration timeout)
      Count the points in a collection with the given filtering conditions.
      Parameters:
      collectionName - The name of the collection.
      filter - Filter conditions - return only those points that satisfy the specified conditions.
      exact - If true, returns the exact count, if false, returns an approximate count. Defaults to true.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • queryAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.ScoredPoint>> queryAsync(io.qdrant.client.grpc.Points.QueryPoints request)
      Universally query points. Covers all capabilities of search, recommend, discover, filters. Also enables hybrid and multi-stage queries.
      Parameters:
      request - the query request
      Returns:
      a new instance of ListenableFuture

    • queryAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.ScoredPoint>> queryAsync(io.qdrant.client.grpc.Points.QueryPoints request, @Nullable Duration timeout)
      Universally query points. Covers all capabilities of search, recommend, discover, filters. Also enables hybrid and multi-stage queries.
      Parameters:
      request - the query request
      timeout - the timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • queryBatchAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.BatchResult>> queryBatchAsync(String collectionName, List<io.qdrant.client.grpc.Points.QueryPoints> queries)
      Universally query points in batch. Covers all capabilities of search, recommend, discover, filters. Also enables hybrid and multi-stage queries.
      Parameters:
      collectionName - The name of the collection
      queries - The queries to be performed in the batch.
      Returns:
      a new instance of ListenableFuture

    • queryBatchAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.BatchResult>> queryBatchAsync(String collectionName, List<io.qdrant.client.grpc.Points.QueryPoints> queries, @Nullable io.qdrant.client.grpc.Points.ReadConsistency readConsistency)
      Universally query points in batch. Covers all capabilities of search, recommend, discover, filters. Also enables hybrid and multi-stage queries.
      Parameters:
      collectionName - The name of the collection
      queries - The queries to be performed in the batch.
      readConsistency - Options for specifying read consistency guarantees.
      Returns:
      a new instance of ListenableFuture

    • queryBatchAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.BatchResult>> queryBatchAsync(String collectionName, List<io.qdrant.client.grpc.Points.QueryPoints> queries, @Nullable io.qdrant.client.grpc.Points.ReadConsistency readConsistency, @Nullable Duration timeout)
      Universally query points in batch. Covers all capabilities of search, recommend, discover, filters. Also enables hybrid and multi-stage queries.
      Parameters:
      collectionName - The name of the collection
      queries - The queries to be performed in the batch.
      readConsistency - Options for specifying read consistency guarantees.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • queryGroupsAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.PointGroup>> queryGroupsAsync(io.qdrant.client.grpc.Points.QueryPointGroups request)
      Universally query points. Covers all capabilities of search, recommend, discover, filters. Grouped by a payload field.
      Parameters:
      request - the query request
      Returns:
      a new instance of ListenableFuture

    • queryGroupsAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.PointGroup>> queryGroupsAsync(io.qdrant.client.grpc.Points.QueryPointGroups request, @Nullable Duration timeout)
      Universally query points. Covers all capabilities of search, recommend, discover, filters. Grouped by a payload field.
      Parameters:
      request - the query request
      timeout - the timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • facetAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.FacetHit>> facetAsync(io.qdrant.client.grpc.Points.FacetCounts request)
      Perform facet counts. For each value in the field, count the number of points that have this value and match the conditions.
      Parameters:
      request - the facet counts request
      Returns:
      a new instance of ListenableFuture

    • facetAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.Points.FacetHit>> facetAsync(io.qdrant.client.grpc.Points.FacetCounts request, @Nullable Duration timeout)
      Perform facet counts. For each value in the field, count the number of points that have this value and match the conditions.
      Parameters:
      request - the facet counts request
      timeout - the timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • searchMatrixPairsAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.SearchMatrixPairs> searchMatrixPairsAsync(io.qdrant.client.grpc.Points.SearchMatrixPoints request)
      Compute distance matrix for sampled points with a pair based output format.
      Parameters:
      request - the search matrix pairs request
      Returns:
      a new instance of ListenableFuture

    • searchMatrixPairsAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.SearchMatrixPairs> searchMatrixPairsAsync(io.qdrant.client.grpc.Points.SearchMatrixPoints request, @Nullable Duration timeout)
      Compute distance matrix for sampled points with a pair based output format.
      Parameters:
      request - the search matrix pairs request
      timeout - the timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • searchMatrixOffsetsAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.SearchMatrixOffsets> searchMatrixOffsetsAsync(io.qdrant.client.grpc.Points.SearchMatrixPoints request)
      Compute distance matrix for sampled points with an offset based output format
      Parameters:
      request - the search matrix pairs request
      Returns:
      a new instance of ListenableFuture

    • searchMatrixOffsetsAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.Points.SearchMatrixOffsets> searchMatrixOffsetsAsync(io.qdrant.client.grpc.Points.SearchMatrixPoints request, @Nullable Duration timeout)
      Compute distance matrix for sampled points with an offset based output format
      Parameters:
      request - the search matrix pairs request
      timeout - the timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • createSnapshotAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.SnapshotsService.SnapshotDescription> createSnapshotAsync(String collectionName)
      Create snapshot for a given collection.
      Parameters:
      collectionName - The name of the collection.
      Returns:
      a new instance of ListenableFuture

    • createSnapshotAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.SnapshotsService.SnapshotDescription> createSnapshotAsync(String collectionName, @Nullable Duration timeout)
      Create snapshot for a given collection.
      Parameters:
      collectionName - The name of the collection.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • listSnapshotAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.SnapshotsService.SnapshotDescription>> listSnapshotAsync(String collectionName)
      Get list of snapshots for a collection.
      Parameters:
      collectionName - The name of the collection.
      Returns:
      a new instance of ListenableFuture

    • listSnapshotAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.SnapshotsService.SnapshotDescription>> listSnapshotAsync(String collectionName, @Nullable Duration timeout)
      Get list of snapshots for a collection.
      Parameters:
      collectionName - The name of the collection.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • deleteSnapshotAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.SnapshotsService.DeleteSnapshotResponse> deleteSnapshotAsync(String collectionName, String snapshotName)
      Delete snapshot for a given collection.
      Parameters:
      collectionName - The name of the collection.
      snapshotName - The name of the snapshot.
      Returns:
      a new instance of ListenableFuture

    • deleteSnapshotAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.SnapshotsService.DeleteSnapshotResponse> deleteSnapshotAsync(String collectionName, String snapshotName, @Nullable Duration timeout)
      Delete snapshot for a given collection.
      Parameters:
      collectionName - The name of the collection.
      snapshotName - The name of the snapshot.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • createFullSnapshotAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.SnapshotsService.SnapshotDescription> createFullSnapshotAsync()
      Create snapshot for a whole storage.
      Returns:
      a new instance of ListenableFuture

    • createFullSnapshotAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.SnapshotsService.SnapshotDescription> createFullSnapshotAsync(@Nullable Duration timeout)
      Create snapshot for a whole storage.
      Parameters:
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • listFullSnapshotAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.SnapshotsService.SnapshotDescription>> listFullSnapshotAsync()
      Get list of snapshots for a whole storage.
      Returns:
      a new instance of ListenableFuture

    • listFullSnapshotAsync

      public com.google.common.util.concurrent.ListenableFuture<List<io.qdrant.client.grpc.SnapshotsService.SnapshotDescription>> listFullSnapshotAsync(@Nullable Duration timeout)
      Get list of snapshots for a whole storage.
      Parameters:
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • deleteFullSnapshotAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.SnapshotsService.DeleteSnapshotResponse> deleteFullSnapshotAsync(String snapshotName)
      Delete snapshot for a whole storage.
      Parameters:
      snapshotName - The name of the snapshot.
      Returns:
      a new instance of ListenableFuture

    • deleteFullSnapshotAsync

      public com.google.common.util.concurrent.ListenableFuture<io.qdrant.client.grpc.SnapshotsService.DeleteSnapshotResponse> deleteFullSnapshotAsync(String snapshotName, @Nullable Duration timeout)
      Delete snapshot for a whole storage.
      Parameters:
      snapshotName - The name of the snapshot.
      timeout - The timeout for the call.
      Returns:
      a new instance of ListenableFuture

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable