メインコンテンツまでスキップ

getFlushAllState()

Addedv3.0.x

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

public GetFlushAllStateResp getFlushAllState(GetFlushAllStateReq request)

Request Syntax

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.

RETURNS:

GetFlushAllStateResp

EXCEPTIONS:

  • MilvusClientException

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

Example

MilvusClientV2 client = new MilvusClientV2(ConnectConfig.builder()
.uri("YOUR_CLUSTER_ENDPOINT")
.token("YOUR_CLUSTER_TOKEN")
.build());

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());