跳到主要内容
版本：v2.6.x

getFlushAllState()

This operation checks whether a previous flush-all action has finished. Use it when you call flushAll asynchronously and need to poll for completion.

Java
public GetFlushAllStateResp getFlushAllState(GetFlushAllStateReq request)

Request Syntax​

Java
getFlushAllState(GetFlushAllStateReq.builder()
    .databaseName(String databaseName)
    .flushAllTs(Long flushAllTs)
    .build());

BUILDER METHODS:

  • databaseName(String databaseName)

    The database used when flushAll was called.

  • flushAllTs(Long flushAllTs)

    The flush-all timestamp returned by flushAll.

RETURN TYPE:

GetFlushAllStateResp

RETURNS:

A GetFlushAllStateResp object that indicates whether the flush-all operation has completed. The object exposes the following getters:

  • getFlushed() (Boolean) -

    Whether the flush-all operation has completed.

EXCEPTIONS:

  • MilvusClientException

    This exception will be raised when validation fails or the server returns an error for this operation.

Example​

Java
import io.milvus.v2.client.ConnectConfig;
import io.milvus.v2.client.MilvusClientV2;
import io.milvus.v2.service.utility.request.FlushAllReq;
import io.milvus.v2.service.utility.request.GetFlushAllStateReq;
import io.milvus.v2.service.utility.response.FlushAllResp;
import io.milvus.v2.service.utility.response.GetFlushAllStateResp;

ConnectConfig connectConfig = ConnectConfig.builder()
        .uri("http://localhost:19530")
        .token("root:Milvus")
        .build();

MilvusClientV2 client = new MilvusClientV2(connectConfig);

FlushAllResp flush = client.flushAll(FlushAllReq.builder()
        .databaseName("default")
        .build());
GetFlushAllStateResp state = client.getFlushAllState(GetFlushAllStateReq.builder()
        .databaseName("default")
        .flushAllTs(flush.getFlushAllTs())
        .build());
System.out.println(state.getFlushed());