FlushAll()

此操作会刷新 Database 中所有 Collection 的插入缓冲区。请在需要持久化写入的备份或验证工作流之前使用。

c++

Status FlushAll(const FlushAllRequest& request, FlushAllResponse& response)

请求语法

c++

auto request = milvus::FlushAllRequest()
    .WithDatabaseName("default")
    .WithWaitFlushedMs(60000);

请求方法：

• WithDatabaseName(const std::string& db_name)

  指定要刷新其 Collection 的 Database。

• WithWaitFlushedMs(int64_t wait_flushed_ms)

  设置等待所有刷新操作完成的超时时间。设为零表示无限期等待。

返回值：

Status

异常：

• std::exception

  当请求无法发送或响应无法解析时，可能会抛出此异常。

示例

c++

auto client = milvus::MilvusClientV2::Create();
milvus::ConnectParam connect_param{"YOUR_CLUSTER_ENDPOINT", "YOUR_CLUSTER_TOKEN"};
auto status = client->Connect(connect_param);
if (!status.IsOk()) {
    std::cout << status.Message() << std::endl;
}

auto request = milvus::FlushAllRequest()
    .WithDatabaseName("default")
    .WithWaitFlushedMs(60000);
milvus::FlushAllResponse response;
status = client->FlushAll(request, response);
if (!status.IsOk()) {
    std::cout << status.Message() << std::endl;
}