enhance:support minhash function

Signed-off-by: cqy123456 <[email protected]>

Author: cqy123456

pymilvus/client/types.py

@@ -142,6 +142,7 @@ class FunctionType(IntEnum):
     BM25 = 1
     TEXTEMBEDDING = 2
     RERANK = 3
+    MINHASH = 4
 
 
 class RangeType(IntEnum):

pymilvus/grpc_gen/common_pb2.py

@@ -357,6 +357,7 @@ class ObjectPrivilege(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
     PrivilegeAddCollectionFunction: _ClassVar[ObjectPrivilege]
     PrivilegeAlterCollectionFunction: _ClassVar[ObjectPrivilege]
     PrivilegeDropCollectionFunction: _ClassVar[ObjectPrivilege]
+    PrivilegeUpdateReplicateConfiguration: _ClassVar[ObjectPrivilege]
 
 class StateCode(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
     __slots__ = ()
@@ -706,6 +707,7 @@ PrivilegeListFileResources: ObjectPrivilege
 PrivilegeAddCollectionFunction: ObjectPrivilege
 PrivilegeAlterCollectionFunction: ObjectPrivilege
 PrivilegeDropCollectionFunction: ObjectPrivilege
+PrivilegeUpdateReplicateConfiguration: ObjectPrivilege
 Initializing: StateCode
 Healthy: StateCode
 Abnormal: StateCode

pymilvus/grpc_gen/common_pb2.pyi

@@ -41,6 +41,7 @@ class FunctionType(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
     BM25: _ClassVar[FunctionType]
     TextEmbedding: _ClassVar[FunctionType]
     Rerank: _ClassVar[FunctionType]
+    MinHash: _ClassVar[FunctionType]
 
 class FieldState(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
     __slots__ = ()
@@ -76,6 +77,7 @@ Unknown: FunctionType
 BM25: FunctionType
 TextEmbedding: FunctionType
 Rerank: FunctionType
+MinHash: FunctionType
 FieldCreated: FieldState
 FieldCreating: FieldState
 FieldDropping: FieldState
@@ -148,7 +150,7 @@ class FunctionScore(_message.Message):
     def __init__(self, functions: _Optional[_Iterable[_Union[FunctionSchema, _Mapping]]] = ..., params: _Optional[_Iterable[_Union[_common_pb2.KeyValuePair, _Mapping]]] = ...) -> None: ...
 
 class CollectionSchema(_message.Message):
-    __slots__ = ("name", "description", "autoID", "fields", "enable_dynamic_field", "properties", "functions", "dbName", "struct_array_fields")
+    __slots__ = ("name", "description", "autoID", "fields", "enable_dynamic_field", "properties", "functions", "dbName", "struct_array_fields", "version")
     NAME_FIELD_NUMBER: _ClassVar[int]
     DESCRIPTION_FIELD_NUMBER: _ClassVar[int]
     AUTOID_FIELD_NUMBER: _ClassVar[int]
@@ -158,6 +160,7 @@ class CollectionSchema(_message.Message):
     FUNCTIONS_FIELD_NUMBER: _ClassVar[int]
     DBNAME_FIELD_NUMBER: _ClassVar[int]
     STRUCT_ARRAY_FIELDS_FIELD_NUMBER: _ClassVar[int]
+    VERSION_FIELD_NUMBER: _ClassVar[int]
     name: str
     description: str
     autoID: bool
@@ -167,7 +170,8 @@ class CollectionSchema(_message.Message):
     functions: _containers.RepeatedCompositeFieldContainer[FunctionSchema]
     dbName: str
     struct_array_fields: _containers.RepeatedCompositeFieldContainer[StructArrayFieldSchema]
-    def __init__(self, name: _Optional[str] = ..., description: _Optional[str] = ..., autoID: bool = ..., fields: _Optional[_Iterable[_Union[FieldSchema, _Mapping]]] = ..., enable_dynamic_field: bool = ..., properties: _Optional[_Iterable[_Union[_common_pb2.KeyValuePair, _Mapping]]] = ..., functions: _Optional[_Iterable[_Union[FunctionSchema, _Mapping]]] = ..., dbName: _Optional[str] = ..., struct_array_fields: _Optional[_Iterable[_Union[StructArrayFieldSchema, _Mapping]]] = ...) -> None: ...
+    version: int
+    def __init__(self, name: _Optional[str] = ..., description: _Optional[str] = ..., autoID: bool = ..., fields: _Optional[_Iterable[_Union[FieldSchema, _Mapping]]] = ..., enable_dynamic_field: bool = ..., properties: _Optional[_Iterable[_Union[_common_pb2.KeyValuePair, _Mapping]]] = ..., functions: _Optional[_Iterable[_Union[FunctionSchema, _Mapping]]] = ..., dbName: _Optional[str] = ..., struct_array_fields: _Optional[_Iterable[_Union[StructArrayFieldSchema, _Mapping]]] = ..., version: _Optional[int] = ...) -> None: ...
 
 class StructArrayFieldSchema(_message.Message):
     __slots__ = ("fieldID", "name", "description", "fields", "type_params")

pymilvus/grpc_gen/milvus-proto

@@ -906,8 +906,11 @@ def verify(self, schema: CollectionSchema):
             self._check_bm25_function(schema)
         elif self._type == FunctionType.TEXTEMBEDDING:
             self._check_text_embedding_function(schema)
-        elif self._type == FunctionType.RANKER:
-            # We will not check the ranker function here.
+        elif self._type == FunctionType.RERANK:
+            # We will not check the rerank function here.
+            pass
+        elif self._type == FunctionType.MINHASH:
+            # milvus will do the check job
             pass
         elif self._type == FunctionType.UNKNOWN:
             raise ParamError(message=ExceptionsMessage.UnknownFunctionType)