public class MilvusMultiServiceClient extends java.lang.Object implements MilvusClient
| 构造器和说明 |
|---|
MilvusMultiServiceClient(@NonNull MultiConnectParam multiConnectParam)
Sets connect param for multi milvus clusters.
|
| 限定符和类型 | 方法和说明 |
|---|---|
R<RpcStatus> |
alterAlias(AlterAliasParam requestParam)
Alters alias from a collection to another.
|
R<io.milvus.grpc.CalcDistanceResults> |
calcDistance(CalcDistanceParam requestParam)
Calculates the distance between the specified vectors.
|
void |
close(long maxWaitSeconds)
Disconnects from a Milvus server with configurable timeout.
|
R<RpcStatus> |
createAlias(CreateAliasParam requestParam)
Creates an alias for a collection.
|
R<RpcStatus> |
createCollection(CreateCollectionParam requestParam)
Creates a collection in Milvus.
|
R<RpcStatus> |
createCredential(CreateCredentialParam requestParam)
Create credential using the given user and password.
|
R<RpcStatus> |
createIndex(CreateIndexParam requestParam)
Creates an index on a vector field in the specified collection.
|
R<RpcStatus> |
createPartition(CreatePartitionParam requestParam)
Creates a partition in the specified collection.
|
R<io.milvus.grpc.MutationResult> |
delete(DeleteParam requestParam)
Deletes entity(s) based on primary key(s) filtered by boolean expression.
|
R<RpcStatus> |
deleteCredential(DeleteCredentialParam requestParam)
Delete credential corresponding to the user.
|
R<io.milvus.grpc.DescribeCollectionResponse> |
describeCollection(DescribeCollectionParam requestParam)
Shows the details of a collection, e.g. name, schema.
|
R<io.milvus.grpc.DescribeIndexResponse> |
describeIndex(DescribeIndexParam requestParam)
Shows the information of the specified index.
|
R<RpcStatus> |
dropAlias(DropAliasParam requestParam)
Drops an alias for the specified collection.
|
R<RpcStatus> |
dropCollection(DropCollectionParam requestParam)
Drops a collection.
|
R<RpcStatus> |
dropIndex(DropIndexParam requestParam)
Drops the index on a vector field in the specified collection.
|
R<RpcStatus> |
dropPartition(DropPartitionParam requestParam)
Drops a partition.
|
R<io.milvus.grpc.FlushResponse> |
flush(FlushParam requestParam)
Flushes collections.
|
R<io.milvus.grpc.GetCollectionStatisticsResponse> |
getCollectionStatistics(GetCollectionStatisticsParam requestParam)
Shows the statistics information of a collection.
|
R<io.milvus.grpc.GetCompactionStateResponse> |
getCompactionState(GetCompactionStateParam requestParam)
Gets the compaction state by id.
|
R<io.milvus.grpc.GetCompactionPlansResponse> |
getCompactionStateWithPlans(GetCompactionPlansParam requestParam)
Gets compaction state with its plan.
|
R<io.milvus.grpc.GetFlushStateResponse> |
getFlushState(GetFlushStateParam requestParam)
Get flush state of specified segments.
|
R<io.milvus.grpc.GetIndexBuildProgressResponse> |
getIndexBuildProgress(GetIndexBuildProgressParam requestParam)
Shows the index building progress, such as how many rows are indexed.
|
R<io.milvus.grpc.GetIndexStateResponse> |
getIndexState(GetIndexStateParam requestParam)
Shows the index building state(in-progress/finished/failed), and the reason for failure (if any).
|
R<io.milvus.grpc.GetMetricsResponse> |
getMetrics(GetMetricsParam requestParam)
Gets the runtime metrics information of Milvus, returns the result in .json format.
|
R<io.milvus.grpc.GetPartitionStatisticsResponse> |
getPartitionStatistics(GetPartitionStatisticsParam requestParam)
Shows the statistics information of a partition.
|
R<io.milvus.grpc.GetPersistentSegmentInfoResponse> |
getPersistentSegmentInfo(GetPersistentSegmentInfoParam requestParam)
Gets the information of persistent segments from data node, including row count,
persistence state(growing or flushed), etc.
|
R<io.milvus.grpc.GetQuerySegmentInfoResponse> |
getQuerySegmentInfo(GetQuerySegmentInfoParam requestParam)
Gets the query information of segments in a collection from query node, including row count,
memory usage size, index name, etc.
|
R<io.milvus.grpc.GetReplicasResponse> |
getReplicas(GetReplicasParam requestParam)
Returns the collection's replica information
|
R<java.lang.Boolean> |
hasCollection(HasCollectionParam requestParam)
Checks if a collection exists.
|
R<java.lang.Boolean> |
hasPartition(HasPartitionParam requestParam)
Checks if a partition exists in the specified collection.
|
R<io.milvus.grpc.MutationResult> |
insert(InsertParam requestParam)
Inserts entities into a specified collection .
|
com.google.common.util.concurrent.ListenableFuture<R<io.milvus.grpc.MutationResult>> |
insertAsync(InsertParam requestParam)
Inserts entities into a specified collection asynchronously.
|
R<io.milvus.grpc.ListCredUsersResponse> |
listCredUsers(ListCredUsersParam requestParam)
List all user names.
|
R<RpcStatus> |
loadBalance(LoadBalanceParam requestParam)
Moves segment from a query node to another to keep the load balanced.
|
R<RpcStatus> |
loadCollection(LoadCollectionParam requestParam)
Loads a collection to memory before search or query.
|
R<RpcStatus> |
loadPartitions(LoadPartitionsParam requestParam)
Loads a partition into memory.
|
R<io.milvus.grpc.ManualCompactionResponse> |
manualCompact(ManualCompactParam requestParam)
Performs a manual compaction.
|
R<io.milvus.grpc.QueryResults> |
query(QueryParam requestParam)
Queries entity(s) based on scalar field(s) filtered by boolean expression.
|
com.google.common.util.concurrent.ListenableFuture<R<io.milvus.grpc.QueryResults>> |
queryAsync(QueryParam requestParam)
Queries entity(s) asynchronously based on scalar field(s) filtered by boolean expression.
|
R<RpcStatus> |
releaseCollection(ReleaseCollectionParam requestParam)
Releases a collection from memory to reduce memory usage.
|
R<RpcStatus> |
releasePartitions(ReleasePartitionsParam requestParam)
Releases a partition from memory.
|
R<io.milvus.grpc.SearchResults> |
search(SearchParam requestParam)
Conducts ANN search on a vector field.
|
com.google.common.util.concurrent.ListenableFuture<R<io.milvus.grpc.SearchResults>> |
searchAsync(SearchParam requestParam)
Conducts ANN search on a vector field asynchronously.
|
R<io.milvus.grpc.ShowCollectionsResponse> |
showCollections(ShowCollectionsParam requestParam)
Lists all collections or gets collection loading status.
|
R<io.milvus.grpc.ShowPartitionsResponse> |
showPartitions(ShowPartitionsParam requestParam)
Shows all partitions in the specified collection.
|
R<RpcStatus> |
updateCredential(UpdateCredentialParam requestParam)
Update credential using the given user and password.
|
MilvusClient |
withTimeout(long timeout,
java.util.concurrent.TimeUnit timeoutUnit)
Timeout setting for rpc call.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitclosepublic MilvusMultiServiceClient(@NonNull
@NonNull MultiConnectParam multiConnectParam)
multiConnectParam - multi server connect parampublic MilvusClient withTimeout(long timeout, java.util.concurrent.TimeUnit timeoutUnit)
MilvusClientwithTimeout 在接口中 MilvusClienttimeout - set time waiting for a rpc call.timeoutUnit - time unitpublic void close(long maxWaitSeconds)
throws java.lang.InterruptedException
MilvusClientclose 在接口中 MilvusClientmaxWaitSeconds - timeout unit: secondjava.lang.InterruptedExceptionpublic R<java.lang.Boolean> hasCollection(HasCollectionParam requestParam)
MilvusClienthasCollection 在接口中 MilvusClientrequestParam - HasCollectionParampublic R<RpcStatus> createCollection(CreateCollectionParam requestParam)
MilvusClientcreateCollection 在接口中 MilvusClientrequestParam - CreateCollectionParampublic R<RpcStatus> dropCollection(DropCollectionParam requestParam)
MilvusClientdropCollection 在接口中 MilvusClientrequestParam - DropCollectionParampublic R<RpcStatus> loadCollection(LoadCollectionParam requestParam)
MilvusClientloadCollection 在接口中 MilvusClientrequestParam - LoadCollectionParampublic R<RpcStatus> releaseCollection(ReleaseCollectionParam requestParam)
MilvusClientreleaseCollection 在接口中 MilvusClientrequestParam - ReleaseCollectionParampublic R<io.milvus.grpc.DescribeCollectionResponse> describeCollection(DescribeCollectionParam requestParam)
MilvusClientdescribeCollection 在接口中 MilvusClientrequestParam - DescribeCollectionParampublic R<io.milvus.grpc.GetCollectionStatisticsResponse> getCollectionStatistics(GetCollectionStatisticsParam requestParam)
MilvusClientgetCollectionStatistics 在接口中 MilvusClientrequestParam - GetCollectionStatisticsParampublic R<io.milvus.grpc.ShowCollectionsResponse> showCollections(ShowCollectionsParam requestParam)
MilvusClientshowCollections 在接口中 MilvusClientrequestParam - ShowCollectionsParampublic R<io.milvus.grpc.FlushResponse> flush(FlushParam requestParam)
MilvusClientflush 在接口中 MilvusClientrequestParam - FlushParampublic R<RpcStatus> createPartition(CreatePartitionParam requestParam)
MilvusClientcreatePartition 在接口中 MilvusClientrequestParam - CreatePartitionParampublic R<RpcStatus> dropPartition(DropPartitionParam requestParam)
MilvusClientdropPartition 在接口中 MilvusClientrequestParam - DropPartitionParampublic R<java.lang.Boolean> hasPartition(HasPartitionParam requestParam)
MilvusClienthasPartition 在接口中 MilvusClientrequestParam - HasPartitionParampublic R<RpcStatus> loadPartitions(LoadPartitionsParam requestParam)
MilvusClientloadPartitions 在接口中 MilvusClientrequestParam - LoadPartitionsParampublic R<RpcStatus> releasePartitions(ReleasePartitionsParam requestParam)
MilvusClientreleasePartitions 在接口中 MilvusClientrequestParam - ReleasePartitionsParampublic R<io.milvus.grpc.GetPartitionStatisticsResponse> getPartitionStatistics(GetPartitionStatisticsParam requestParam)
MilvusClientgetPartitionStatistics 在接口中 MilvusClientrequestParam - GetPartitionStatisticsParampublic R<io.milvus.grpc.ShowPartitionsResponse> showPartitions(ShowPartitionsParam requestParam)
MilvusClientshowPartitions 在接口中 MilvusClientrequestParam - ShowPartitionsParampublic R<RpcStatus> createAlias(CreateAliasParam requestParam)
MilvusClientcreateAlias 在接口中 MilvusClientrequestParam - CreateAliasParampublic R<RpcStatus> dropAlias(DropAliasParam requestParam)
MilvusClientdropAlias 在接口中 MilvusClientrequestParam - DropAliasParampublic R<RpcStatus> alterAlias(AlterAliasParam requestParam)
MilvusClientalterAlias 在接口中 MilvusClientrequestParam - AlterAliasParampublic R<RpcStatus> createIndex(CreateIndexParam requestParam)
MilvusClientcreateIndex 在接口中 MilvusClientrequestParam - CreateIndexParampublic R<RpcStatus> dropIndex(DropIndexParam requestParam)
MilvusClientdropIndex 在接口中 MilvusClientrequestParam - DropIndexParampublic R<io.milvus.grpc.DescribeIndexResponse> describeIndex(DescribeIndexParam requestParam)
MilvusClientdescribeIndex 在接口中 MilvusClientrequestParam - DescribeIndexParampublic R<io.milvus.grpc.GetIndexStateResponse> getIndexState(GetIndexStateParam requestParam)
MilvusClientgetIndexState 在接口中 MilvusClientrequestParam - GetIndexStateParampublic R<io.milvus.grpc.GetIndexBuildProgressResponse> getIndexBuildProgress(GetIndexBuildProgressParam requestParam)
MilvusClientgetIndexBuildProgress 在接口中 MilvusClientrequestParam - GetIndexBuildProgressParampublic R<io.milvus.grpc.MutationResult> insert(InsertParam requestParam)
MilvusClientinsert 在接口中 MilvusClientrequestParam - InsertParampublic com.google.common.util.concurrent.ListenableFuture<R<io.milvus.grpc.MutationResult>> insertAsync(InsertParam requestParam)
MilvusClientinsertAsync 在接口中 MilvusClientrequestParam - InsertParamListenableFuture object which holds the object {status:result code, data: MutationResult{insert results}}public R<io.milvus.grpc.MutationResult> delete(DeleteParam requestParam)
MilvusClientdelete 在接口中 MilvusClientrequestParam - DeleteParampublic R<io.milvus.grpc.SearchResults> search(SearchParam requestParam)
MilvusClientsearch 在接口中 MilvusClientrequestParam - SearchParampublic com.google.common.util.concurrent.ListenableFuture<R<io.milvus.grpc.SearchResults>> searchAsync(SearchParam requestParam)
MilvusClientsearchAsync 在接口中 MilvusClientrequestParam - SearchParamListenableFuture object which holds the object {status:result code, data: SearchResults{topK results}}public R<io.milvus.grpc.QueryResults> query(QueryParam requestParam)
MilvusClientquery 在接口中 MilvusClientrequestParam - QueryParampublic com.google.common.util.concurrent.ListenableFuture<R<io.milvus.grpc.QueryResults>> queryAsync(QueryParam requestParam)
MilvusClientqueryAsync 在接口中 MilvusClientrequestParam - QueryParampublic R<io.milvus.grpc.CalcDistanceResults> calcDistance(CalcDistanceParam requestParam)
MilvusClientcalcDistance 在接口中 MilvusClientrequestParam - CalcDistanceParampublic R<io.milvus.grpc.GetMetricsResponse> getMetrics(GetMetricsParam requestParam)
MilvusClientgetMetrics 在接口中 MilvusClientrequestParam - GetMetricsParampublic R<io.milvus.grpc.GetFlushStateResponse> getFlushState(GetFlushStateParam requestParam)
MilvusClientgetFlushState 在接口中 MilvusClientrequestParam - GetFlushStateParampublic R<io.milvus.grpc.GetPersistentSegmentInfoResponse> getPersistentSegmentInfo(GetPersistentSegmentInfoParam requestParam)
MilvusClientgetPersistentSegmentInfo 在接口中 MilvusClientrequestParam - GetPersistentSegmentInfoParampublic R<io.milvus.grpc.GetQuerySegmentInfoResponse> getQuerySegmentInfo(GetQuerySegmentInfoParam requestParam)
MilvusClientgetQuerySegmentInfo 在接口中 MilvusClientrequestParam - GetQuerySegmentInfoParampublic R<io.milvus.grpc.GetReplicasResponse> getReplicas(GetReplicasParam requestParam)
MilvusClientgetReplicas 在接口中 MilvusClientrequestParam - GetReplicasParampublic R<RpcStatus> loadBalance(LoadBalanceParam requestParam)
MilvusClientloadBalance 在接口中 MilvusClientrequestParam - LoadBalanceParampublic R<io.milvus.grpc.GetCompactionStateResponse> getCompactionState(GetCompactionStateParam requestParam)
MilvusClientgetCompactionState 在接口中 MilvusClientrequestParam - GetCompactionStateParampublic R<io.milvus.grpc.ManualCompactionResponse> manualCompact(ManualCompactParam requestParam)
MilvusClientmanualCompact 在接口中 MilvusClientrequestParam - ManualCompactParampublic R<io.milvus.grpc.GetCompactionPlansResponse> getCompactionStateWithPlans(GetCompactionPlansParam requestParam)
MilvusClientgetCompactionStateWithPlans 在接口中 MilvusClientrequestParam - GetCompactionPlansParampublic R<RpcStatus> createCredential(CreateCredentialParam requestParam)
MilvusClientcreateCredential 在接口中 MilvusClientrequestParam - CreateCredentialParampublic R<RpcStatus> updateCredential(UpdateCredentialParam requestParam)
MilvusClientupdateCredential 在接口中 MilvusClientrequestParam - UpdateCredentialParampublic R<RpcStatus> deleteCredential(DeleteCredentialParam requestParam)
MilvusClientdeleteCredential 在接口中 MilvusClientrequestParam - DeleteCredentialParampublic R<io.milvus.grpc.ListCredUsersResponse> listCredUsers(ListCredUsersParam requestParam)
MilvusClientlistCredUsers 在接口中 MilvusClientrequestParam - ListCredUsersParam