Page Comparison

...

def delete(self, condition=None)->MutationResult:
    """
    Delete entities by primary keys.
    Example: client.delete("_id in [1,10,100]")
    
    :param condition: an expression indicates whether an entity should be deleted
    :type  condition: str
    """

Design Details

In Milvus, Proxy maintains 2 kinds of pulsar Pulsar channels for each collection:

1. insert channelInsert channel, handle following msg types:
   1. DDL msg (CreateCollection/DropCollection/CreatePartition/DropPartition)
   2. InsertMsg
   3. DeleteMsg
2. search channelSearch channel, handle following msg types:
   1. SearchMsg
   2. RetrieveMsg

DataNode consumes messages from insert Insert channel only.

QueryNode consumes messages from both insert Insert channel and search Search channel.

To support delete, we will send DeleteMsg into insert Insert channel also.

Since Milvus's storage is an append-only, `delete` function is implemented using soft delete, setting a flag on entity to indicate this entity has been deleted.

...