public class MilvusMultiServiceClient extends java.lang.Object implements MilvusClient
Constructor and Description |
---|
MilvusMultiServiceClient(@NonNull MultiConnectParam multiConnectParam)
Sets connect param for multi milvus clusters.
|
Modifier and Type | Method and Description |
---|---|
R<RpcStatus> |
addUserToRole(AddUserToRoleParam requestParam)
The user will get permissions that the role are allowed to perform operations.
|
R<RpcStatus> |
alterAlias(AlterAliasParam requestParam)
Alters alias from a collection to another.
|
R<RpcStatus> |
alterCollection(AlterCollectionParam requestParam)
Alter collection with key-value properties.
|
R<RpcStatus> |
alterDatabase(AlterDatabaseParam requestParam)
Alter database with key value pair.
|
R<RpcStatus> |
alterIndex(AlterIndexParam requestParam)
Alter index with key value properties.
|
R<io.milvus.grpc.ImportResponse> |
bulkInsert(BulkInsertParam requestParam)
Import data from external files, currently support JSON format
|
R<io.milvus.grpc.CheckHealthResponse> |
checkHealth()
Check server health
|
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> |
createCollection(CreateSimpleCollectionParam requestParam)
Creates a collection in Milvus.
|
R<RpcStatus> |
createCredential(CreateCredentialParam requestParam)
Create credential using the given user and password.
|
R<RpcStatus> |
createDatabase(CreateDatabaseParam requestParam)
Creates a database in Milvus.
|
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<RpcStatus> |
createResourceGroup(CreateResourceGroupParam requestParam)
Create a resource group.
|
R<RpcStatus> |
createRole(CreateRoleParam requestParam)
It will success if the role isn't existed, otherwise fail.
|
R<DeleteResponse> |
delete(DeleteIdsParam requestParam)
Deletes entity(s) based on the value of primary key.
|
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.
|
R<io.milvus.grpc.DescribeDatabaseResponse> |
describeDatabase(DescribeDatabaseParam requestParam)
Show detail of database base, such as replica number and resource groups.
|
R<io.milvus.grpc.DescribeIndexResponse> |
describeIndex(DescribeIndexParam requestParam)
Shows the information of the specified index.
|
R<io.milvus.grpc.DescribeResourceGroupResponse> |
describeResourceGroup(DescribeResourceGroupParam requestParam)
Describe a resource group.
|
R<RpcStatus> |
dropAlias(DropAliasParam requestParam)
Drops an alias for the specified collection.
|
R<RpcStatus> |
dropCollection(DropCollectionParam requestParam)
Drops a collection.
|
R<RpcStatus> |
dropDatabase(DropDatabaseParam requestParam)
Drops a database.
|
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<RpcStatus> |
dropResourceGroup(DropResourceGroupParam requestParam)
Drop a resource group.
|
R<RpcStatus> |
dropRole(DropRoleParam requestParam)
It will success if the role is existed, otherwise fail.
|
R<io.milvus.grpc.FlushResponse> |
flush(FlushParam requestParam)
Flushes inserted data in buffer into storage.
|
R<io.milvus.grpc.FlushAllResponse> |
flushAll(boolean syncFlushAll,
long syncFlushAllWaitingInterval,
long syncFlushAllTimeout)
Flush all collections.
|
R<GetResponse> |
get(GetIdsParam requestParam)
Get entity(s) based on the value of primary key.
|
R<io.milvus.grpc.GetImportStateResponse> |
getBulkInsertState(GetBulkInsertStateParam requestParam)
Get state of bulk insert task
|
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.GetFlushAllStateResponse> |
getFlushAllState(GetFlushAllStateParam requestParam)
Get flush state of all segments.
|
R<io.milvus.grpc.GetFlushStateResponse> |
getFlushState(GetFlushStateParam requestParam)
Get flush state of specified collection.
|
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.GetLoadingProgressResponse> |
getLoadingProgress(GetLoadingProgressParam requestParam)
Get collection loading progress
|
R<io.milvus.grpc.GetLoadStateResponse> |
getLoadState(GetLoadStateParam requestParam)
Get collection loading state
|
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<io.milvus.grpc.GetVersionResponse> |
getVersion()
Get server version
|
R<RpcStatus> |
grantRolePrivilege(GrantRolePrivilegeParam requestParam)
Grant Role Privilege.
|
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.SearchResults> |
hybridSearch(HybridSearchParam requestParam)
Conducts multi vector similarity search with a ranker for rearrangement.
|
com.google.common.util.concurrent.ListenableFuture<R<io.milvus.grpc.SearchResults>> |
hybridSearchAsync(HybridSearchParam requestParam)
Conducts multi vector similarity search asynchronously with a ranker for rearrangement.
|
R<io.milvus.grpc.MutationResult> |
insert(InsertParam requestParam)
Inserts entities into a specified collection .
|
R<InsertResponse> |
insert(InsertRowsParam requestParam)
Inserts rows data 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.ListAliasesResponse> |
listAliases(ListAliasesParam requestParam)
List all alias for a collection.
|
R<io.milvus.grpc.ListImportTasksResponse> |
listBulkInsertTasks(ListBulkInsertTasksParam requestParam)
List bulk insert tasks
|
R<ListCollectionsResponse> |
listCollections(ListCollectionsParam requestParam)
Lists all collections
|
R<io.milvus.grpc.ListCredUsersResponse> |
listCredUsers(ListCredUsersParam requestParam)
List all user names.
|
R<io.milvus.grpc.ListDatabasesResponse> |
listDatabases()
List databases.
|
R<io.milvus.grpc.ListResourceGroupsResponse> |
listResourceGroups(ListResourceGroupsParam requestParam)
List resource groups.
|
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.
|
R<QueryResponse> |
query(QuerySimpleParam 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<QueryIterator> |
queryIterator(QueryIteratorParam requestParam)
Get queryIterator 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<RpcStatus> |
removeUserFromRole(RemoveUserFromRoleParam requestParam)
The user will remove permissions that the role are allowed to perform operations.
|
R<RpcStatus> |
renameCollection(RenameCollectionParam requestParam)
rename a collection
|
R<RpcStatus> |
revokeRolePrivilege(RevokeRolePrivilegeParam requestParam)
Revoke Role Privilege.
|
R<io.milvus.grpc.SearchResults> |
search(SearchParam requestParam)
Conducts ANN search on a vector field.
|
R<SearchResponse> |
search(SearchSimpleParam 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<SearchIterator> |
searchIterator(SearchIteratorParam requestParam)
Get searchIterator based on a vector field.
|
R<io.milvus.grpc.SelectGrantResponse> |
selectGrantForRole(SelectGrantForRoleParam requestParam)
List a grant info for the role and the specific object
|
R<io.milvus.grpc.SelectGrantResponse> |
selectGrantForRoleAndObject(SelectGrantForRoleAndObjectParam requestParam)
List a grant info for the role
|
R<io.milvus.grpc.SelectRoleResponse> |
selectRole(SelectRoleParam requestParam)
Get all users who are added to the role.
|
R<io.milvus.grpc.SelectUserResponse> |
selectUser(SelectUserParam requestParam)
Get all roles the user has.
|
void |
setLogLevel(LogLevel level)
Set log level in runtime.
|
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> |
transferNode(TransferNodeParam requestParam)
Transfer a query node from source resource group to target resource_group.
|
R<RpcStatus> |
transferReplica(TransferReplicaParam requestParam)
Transfer a replica from source resource group to target resource_group.
|
R<RpcStatus> |
updateCredential(UpdateCredentialParam requestParam)
Update credential using the given user and password.
|
R<RpcStatus> |
updateResourceGroups(UpdateResourceGroupsParam requestParam)
Update resource groups.
|
R<io.milvus.grpc.MutationResult> |
upsert(UpsertParam requestParam)
Insert new entities into a specified collection, replace them if the entities already exist.
|
com.google.common.util.concurrent.ListenableFuture<R<io.milvus.grpc.MutationResult>> |
upsertAsync(UpsertParam requestParam)
Insert new entities into a specified collection asynchronously, replace them if the entities already exist.
|
MilvusClient |
withRetry(int retryTimes)
Number of retry attempts.
|
MilvusClient |
withRetry(RetryParam retryParam)
Sets the parameters for retry.
|
MilvusClient |
withRetryInterval(long interval,
java.util.concurrent.TimeUnit timeUnit)
Time interval between retry attempts.
|
MilvusClient |
withTimeout(long timeout,
java.util.concurrent.TimeUnit timeoutUnit)
Timeout setting for rpc call.
|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
public MilvusMultiServiceClient(@NonNull @NonNull MultiConnectParam multiConnectParam)
multiConnectParam
- multi server connect parampublic MilvusClient withTimeout(long timeout, java.util.concurrent.TimeUnit timeoutUnit)
MilvusClient
withTimeout
in interface MilvusClient
timeout
- set time waiting for a rpc call.timeoutUnit
- time unitMilvusClient
public MilvusClient withRetry(RetryParam retryParam)
MilvusClient
withRetry
in interface MilvusClient
retryParam
- RetryParam
MilvusClient
public MilvusClient withRetry(int retryTimes)
MilvusClient
withRetry
in interface MilvusClient
retryTimes
- number of retry attempts.MilvusClient
public MilvusClient withRetryInterval(long interval, java.util.concurrent.TimeUnit timeUnit)
MilvusClient
withRetryInterval
in interface MilvusClient
interval
- time interval between retry attempts.timeUnit
- time unitMilvusClient
public void close(long maxWaitSeconds) throws java.lang.InterruptedException
MilvusClient
close
in interface MilvusClient
maxWaitSeconds
- timeout unit: secondjava.lang.InterruptedException
- throw InterruptedException if the client failed to close connectionpublic void setLogLevel(LogLevel level)
MilvusClient
setLogLevel
in interface MilvusClient
level
- LogLevel
public R<java.lang.Boolean> hasCollection(HasCollectionParam requestParam)
MilvusClient
hasCollection
in interface MilvusClient
requestParam
- HasCollectionParam
public R<RpcStatus> createDatabase(CreateDatabaseParam requestParam)
MilvusClient
createDatabase
in interface MilvusClient
requestParam
- CreateDatabaseParam
public R<RpcStatus> dropDatabase(DropDatabaseParam requestParam)
MilvusClient
dropDatabase
in interface MilvusClient
requestParam
- DropDatabaseParam
public R<io.milvus.grpc.ListDatabasesResponse> listDatabases()
MilvusClient
listDatabases
in interface MilvusClient
public R<RpcStatus> alterDatabase(AlterDatabaseParam requestParam)
MilvusClient
alterDatabase
in interface MilvusClient
requestParam
- AlterDatabaseParam
public R<io.milvus.grpc.DescribeDatabaseResponse> describeDatabase(DescribeDatabaseParam requestParam)
MilvusClient
describeDatabase
in interface MilvusClient
requestParam
- DescribeDatabaseParam
public R<RpcStatus> createCollection(CreateCollectionParam requestParam)
MilvusClient
createCollection
in interface MilvusClient
requestParam
- CreateCollectionParam
public R<RpcStatus> dropCollection(DropCollectionParam requestParam)
MilvusClient
dropCollection
in interface MilvusClient
requestParam
- DropCollectionParam
public R<RpcStatus> loadCollection(LoadCollectionParam requestParam)
MilvusClient
loadCollection
in interface MilvusClient
requestParam
- LoadCollectionParam
public R<RpcStatus> releaseCollection(ReleaseCollectionParam requestParam)
MilvusClient
releaseCollection
in interface MilvusClient
requestParam
- ReleaseCollectionParam
public R<RpcStatus> renameCollection(RenameCollectionParam requestParam)
MilvusClient
renameCollection
in interface MilvusClient
requestParam
- RenameCollectionParam
public R<io.milvus.grpc.DescribeCollectionResponse> describeCollection(DescribeCollectionParam requestParam)
MilvusClient
describeCollection
in interface MilvusClient
requestParam
- DescribeCollectionParam
public R<io.milvus.grpc.GetCollectionStatisticsResponse> getCollectionStatistics(GetCollectionStatisticsParam requestParam)
MilvusClient
getCollectionStatistics
in interface MilvusClient
requestParam
- GetCollectionStatisticsParam
public R<io.milvus.grpc.ShowCollectionsResponse> showCollections(ShowCollectionsParam requestParam)
MilvusClient
showCollections
in interface MilvusClient
requestParam
- ShowCollectionsParam
public R<RpcStatus> alterCollection(AlterCollectionParam requestParam)
MilvusClient
alterCollection
in interface MilvusClient
requestParam
- AlterCollectionParam
public R<io.milvus.grpc.FlushResponse> flush(FlushParam requestParam)
MilvusClient
flush
in interface MilvusClient
requestParam
- FlushParam
public R<io.milvus.grpc.FlushAllResponse> flushAll(boolean syncFlushAll, long syncFlushAllWaitingInterval, long syncFlushAllTimeout)
MilvusClient
flushAll
in interface MilvusClient
syncFlushAll
- {flushAll synchronously or asynchronously}syncFlushAllWaitingInterval
- {wait intervel when flushAll synchronously}syncFlushAllTimeout
- {timeout when flushAll synchronously}public R<RpcStatus> createPartition(CreatePartitionParam requestParam)
MilvusClient
createPartition
in interface MilvusClient
requestParam
- CreatePartitionParam
public R<RpcStatus> dropPartition(DropPartitionParam requestParam)
MilvusClient
dropPartition
in interface MilvusClient
requestParam
- DropPartitionParam
public R<java.lang.Boolean> hasPartition(HasPartitionParam requestParam)
MilvusClient
hasPartition
in interface MilvusClient
requestParam
- HasPartitionParam
public R<RpcStatus> loadPartitions(LoadPartitionsParam requestParam)
MilvusClient
loadPartitions
in interface MilvusClient
requestParam
- LoadPartitionsParam
public R<RpcStatus> releasePartitions(ReleasePartitionsParam requestParam)
MilvusClient
releasePartitions
in interface MilvusClient
requestParam
- ReleasePartitionsParam
public R<io.milvus.grpc.GetPartitionStatisticsResponse> getPartitionStatistics(GetPartitionStatisticsParam requestParam)
MilvusClient
getPartitionStatistics
in interface MilvusClient
requestParam
- GetPartitionStatisticsParam
public R<io.milvus.grpc.ShowPartitionsResponse> showPartitions(ShowPartitionsParam requestParam)
MilvusClient
showPartitions
in interface MilvusClient
requestParam
- ShowPartitionsParam
public R<RpcStatus> createAlias(CreateAliasParam requestParam)
MilvusClient
createAlias
in interface MilvusClient
requestParam
- CreateAliasParam
public R<RpcStatus> dropAlias(DropAliasParam requestParam)
MilvusClient
dropAlias
in interface MilvusClient
requestParam
- DropAliasParam
public R<RpcStatus> alterAlias(AlterAliasParam requestParam)
MilvusClient
alterAlias
in interface MilvusClient
requestParam
- AlterAliasParam
public R<io.milvus.grpc.ListAliasesResponse> listAliases(ListAliasesParam requestParam)
MilvusClient
listAliases
in interface MilvusClient
requestParam
- ListAliasesParam
public R<RpcStatus> createIndex(CreateIndexParam requestParam)
MilvusClient
createIndex
in interface MilvusClient
requestParam
- CreateIndexParam
public R<RpcStatus> dropIndex(DropIndexParam requestParam)
MilvusClient
dropIndex
in interface MilvusClient
requestParam
- DropIndexParam
public R<io.milvus.grpc.DescribeIndexResponse> describeIndex(DescribeIndexParam requestParam)
MilvusClient
describeIndex
in interface MilvusClient
requestParam
- DescribeIndexParam
public R<io.milvus.grpc.GetIndexStateResponse> getIndexState(GetIndexStateParam requestParam)
MilvusClient
getIndexState
in interface MilvusClient
requestParam
- GetIndexStateParam
public R<io.milvus.grpc.GetIndexBuildProgressResponse> getIndexBuildProgress(GetIndexBuildProgressParam requestParam)
MilvusClient
getIndexBuildProgress
in interface MilvusClient
requestParam
- GetIndexBuildProgressParam
public R<RpcStatus> alterIndex(AlterIndexParam requestParam)
MilvusClient
alterIndex
in interface MilvusClient
requestParam
- AlterIndexParam
public R<io.milvus.grpc.MutationResult> insert(InsertParam requestParam)
MilvusClient
insert
in interface MilvusClient
requestParam
- InsertParam
public com.google.common.util.concurrent.ListenableFuture<R<io.milvus.grpc.MutationResult>> insertAsync(InsertParam requestParam)
MilvusClient
insertAsync
in interface MilvusClient
requestParam
- InsertParam
ListenableFuture
object which holds the object {status:result code, data: MutationResult{insert results}}public R<io.milvus.grpc.MutationResult> upsert(UpsertParam requestParam)
MilvusClient
upsert
in interface MilvusClient
requestParam
- UpsertParam
public com.google.common.util.concurrent.ListenableFuture<R<io.milvus.grpc.MutationResult>> upsertAsync(UpsertParam requestParam)
MilvusClient
upsertAsync
in interface MilvusClient
requestParam
- UpsertParam
ListenableFuture
object which holds the object {status:result code, data: MutationResult{insert results}}public R<io.milvus.grpc.MutationResult> delete(DeleteParam requestParam)
MilvusClient
delete
in interface MilvusClient
requestParam
- DeleteParam
public R<io.milvus.grpc.SearchResults> search(SearchParam requestParam)
MilvusClient
search
in interface MilvusClient
requestParam
- SearchParam
public com.google.common.util.concurrent.ListenableFuture<R<io.milvus.grpc.SearchResults>> searchAsync(SearchParam requestParam)
MilvusClient
searchAsync
in interface MilvusClient
requestParam
- SearchParam
ListenableFuture
object which holds the object {status:result code, data: SearchResults{topK results}}public R<io.milvus.grpc.SearchResults> hybridSearch(HybridSearchParam requestParam)
MilvusClient
hybridSearch
in interface MilvusClient
requestParam
- HybridSearchParam
public com.google.common.util.concurrent.ListenableFuture<R<io.milvus.grpc.SearchResults>> hybridSearchAsync(HybridSearchParam requestParam)
MilvusClient
hybridSearchAsync
in interface MilvusClient
requestParam
- HybridSearchParam
ListenableFuture
object which holds the object {status:result code, data: SearchResults{topK results}}public R<io.milvus.grpc.QueryResults> query(QueryParam requestParam)
MilvusClient
query
in interface MilvusClient
requestParam
- QueryParam
public com.google.common.util.concurrent.ListenableFuture<R<io.milvus.grpc.QueryResults>> queryAsync(QueryParam requestParam)
MilvusClient
queryAsync
in interface MilvusClient
requestParam
- QueryParam
public R<io.milvus.grpc.GetMetricsResponse> getMetrics(GetMetricsParam requestParam)
MilvusClient
getMetrics
in interface MilvusClient
requestParam
- GetMetricsParam
public R<io.milvus.grpc.GetFlushStateResponse> getFlushState(GetFlushStateParam requestParam)
MilvusClient
getFlushState
in interface MilvusClient
requestParam
- GetFlushStateParam
public R<io.milvus.grpc.GetFlushAllStateResponse> getFlushAllState(GetFlushAllStateParam requestParam)
MilvusClient
getFlushAllState
in interface MilvusClient
requestParam
- GetFlushAllStateParam
public R<io.milvus.grpc.GetPersistentSegmentInfoResponse> getPersistentSegmentInfo(GetPersistentSegmentInfoParam requestParam)
MilvusClient
getPersistentSegmentInfo
in interface MilvusClient
requestParam
- GetPersistentSegmentInfoParam
public R<io.milvus.grpc.GetQuerySegmentInfoResponse> getQuerySegmentInfo(GetQuerySegmentInfoParam requestParam)
MilvusClient
getQuerySegmentInfo
in interface MilvusClient
requestParam
- GetQuerySegmentInfoParam
public R<io.milvus.grpc.GetReplicasResponse> getReplicas(GetReplicasParam requestParam)
MilvusClient
getReplicas
in interface MilvusClient
requestParam
- GetReplicasParam
public R<RpcStatus> loadBalance(LoadBalanceParam requestParam)
MilvusClient
loadBalance
in interface MilvusClient
requestParam
- LoadBalanceParam
public R<io.milvus.grpc.GetCompactionStateResponse> getCompactionState(GetCompactionStateParam requestParam)
MilvusClient
getCompactionState
in interface MilvusClient
requestParam
- GetCompactionStateParam
public R<io.milvus.grpc.ManualCompactionResponse> manualCompact(ManualCompactParam requestParam)
MilvusClient
manualCompact
in interface MilvusClient
requestParam
- ManualCompactParam
public R<io.milvus.grpc.GetCompactionPlansResponse> getCompactionStateWithPlans(GetCompactionPlansParam requestParam)
MilvusClient
getCompactionStateWithPlans
in interface MilvusClient
requestParam
- GetCompactionPlansParam
public R<RpcStatus> createCredential(CreateCredentialParam requestParam)
MilvusClient
createCredential
in interface MilvusClient
requestParam
- CreateCredentialParam
public R<RpcStatus> updateCredential(UpdateCredentialParam requestParam)
MilvusClient
updateCredential
in interface MilvusClient
requestParam
- UpdateCredentialParam
public R<RpcStatus> deleteCredential(DeleteCredentialParam requestParam)
MilvusClient
deleteCredential
in interface MilvusClient
requestParam
- DeleteCredentialParam
public R<io.milvus.grpc.ListCredUsersResponse> listCredUsers(ListCredUsersParam requestParam)
MilvusClient
listCredUsers
in interface MilvusClient
requestParam
- ListCredUsersParam
public R<RpcStatus> createRole(CreateRoleParam requestParam)
MilvusClient
createRole
in interface MilvusClient
requestParam
- CreateRoleParam
public R<RpcStatus> dropRole(DropRoleParam requestParam)
MilvusClient
dropRole
in interface MilvusClient
requestParam
- DropRoleParam
public R<RpcStatus> addUserToRole(AddUserToRoleParam requestParam)
MilvusClient
addUserToRole
in interface MilvusClient
requestParam
- AddUserToRoleParam
public R<RpcStatus> removeUserFromRole(RemoveUserFromRoleParam requestParam)
MilvusClient
removeUserFromRole
in interface MilvusClient
requestParam
- AddUserToRoleParam
public R<io.milvus.grpc.SelectRoleResponse> selectRole(SelectRoleParam requestParam)
MilvusClient
selectRole
in interface MilvusClient
requestParam
- SelectRoleParam
public R<io.milvus.grpc.SelectUserResponse> selectUser(SelectUserParam requestParam)
MilvusClient
selectUser
in interface MilvusClient
requestParam
- SelectUserParam
public R<RpcStatus> grantRolePrivilege(GrantRolePrivilegeParam requestParam)
MilvusClient
grantRolePrivilege
in interface MilvusClient
requestParam
- GrantRolePrivilegeParam
public R<RpcStatus> revokeRolePrivilege(RevokeRolePrivilegeParam requestParam)
MilvusClient
revokeRolePrivilege
in interface MilvusClient
requestParam
- RevokeRolePrivilegeParam
public R<io.milvus.grpc.SelectGrantResponse> selectGrantForRole(SelectGrantForRoleParam requestParam)
MilvusClient
selectGrantForRole
in interface MilvusClient
requestParam
- SelectGrantForRoleParam
public R<io.milvus.grpc.SelectGrantResponse> selectGrantForRoleAndObject(SelectGrantForRoleAndObjectParam requestParam)
MilvusClient
selectGrantForRoleAndObject
in interface MilvusClient
requestParam
- SelectGrantForRoleAndObjectParam
public R<io.milvus.grpc.ImportResponse> bulkInsert(BulkInsertParam requestParam)
MilvusClient
bulkInsert
in interface MilvusClient
requestParam
- BulkInsertParam
public R<io.milvus.grpc.GetImportStateResponse> getBulkInsertState(GetBulkInsertStateParam requestParam)
MilvusClient
getBulkInsertState
in interface MilvusClient
requestParam
- GetBulkInsertStateParam
public R<io.milvus.grpc.ListImportTasksResponse> listBulkInsertTasks(ListBulkInsertTasksParam requestParam)
MilvusClient
listBulkInsertTasks
in interface MilvusClient
requestParam
- ListBulkInsertTasksParam
public R<io.milvus.grpc.CheckHealthResponse> checkHealth()
MilvusClient
checkHealth
in interface MilvusClient
public R<io.milvus.grpc.GetVersionResponse> getVersion()
MilvusClient
getVersion
in interface MilvusClient
public R<io.milvus.grpc.GetLoadingProgressResponse> getLoadingProgress(GetLoadingProgressParam requestParam)
MilvusClient
getLoadingProgress
in interface MilvusClient
requestParam
- GetLoadingProgressParam
public R<io.milvus.grpc.GetLoadStateResponse> getLoadState(GetLoadStateParam requestParam)
MilvusClient
getLoadState
in interface MilvusClient
requestParam
- GetLoadStateParam
public R<RpcStatus> createResourceGroup(CreateResourceGroupParam requestParam)
MilvusClient
createResourceGroup
in interface MilvusClient
requestParam
- CreateResourceGroupParam
public R<RpcStatus> updateResourceGroups(UpdateResourceGroupsParam requestParam)
MilvusClient
updateResourceGroups
in interface MilvusClient
requestParam
- UpdateResourceGroupsParam
public R<RpcStatus> dropResourceGroup(DropResourceGroupParam requestParam)
MilvusClient
dropResourceGroup
in interface MilvusClient
requestParam
- DropResourceGroupParam
public R<io.milvus.grpc.ListResourceGroupsResponse> listResourceGroups(ListResourceGroupsParam requestParam)
MilvusClient
listResourceGroups
in interface MilvusClient
requestParam
- ListResourceGroupsParam
public R<io.milvus.grpc.DescribeResourceGroupResponse> describeResourceGroup(DescribeResourceGroupParam requestParam)
MilvusClient
describeResourceGroup
in interface MilvusClient
requestParam
- DescribeResourceGroupParam
public R<RpcStatus> transferNode(TransferNodeParam requestParam)
MilvusClient
transferNode
in interface MilvusClient
requestParam
- TransferNodeParam
public R<RpcStatus> transferReplica(TransferReplicaParam requestParam)
MilvusClient
transferReplica
in interface MilvusClient
requestParam
- TransferReplicaParam
public R<RpcStatus> createCollection(CreateSimpleCollectionParam requestParam)
MilvusClient
createCollection
in interface MilvusClient
requestParam
- CreateSimpleCollectionParam
public R<ListCollectionsResponse> listCollections(ListCollectionsParam requestParam)
MilvusClient
listCollections
in interface MilvusClient
requestParam
- ListCollectionsParam
public R<InsertResponse> insert(InsertRowsParam requestParam)
MilvusClient
insert
in interface MilvusClient
requestParam
- InsertRowsParam
public R<DeleteResponse> delete(DeleteIdsParam requestParam)
MilvusClient
delete
in interface MilvusClient
requestParam
- DeleteIdsParam
public R<GetResponse> get(GetIdsParam requestParam)
MilvusClient
get
in interface MilvusClient
requestParam
- GetIdsParam
public R<QueryResponse> query(QuerySimpleParam requestParam)
MilvusClient
query
in interface MilvusClient
requestParam
- QuerySimpleParam
public R<SearchResponse> search(SearchSimpleParam requestParam)
MilvusClient
search
in interface MilvusClient
requestParam
- SearchSimpleParam
public R<QueryIterator> queryIterator(QueryIteratorParam requestParam)
MilvusClient
queryIterator
in interface MilvusClient
requestParam
- QueryIteratorParam
public R<SearchIterator> searchIterator(SearchIteratorParam requestParam)
MilvusClient
searchIterator
in interface MilvusClient
requestParam
- SearchIteratorParam