i need to write a new api GET /_tasks/<task_id>
to check deletion status with a task id. We are using below code to delete certain work objects
BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
boolQueryBuilder.must( QueryBuilders.termsQuery( "_id", deleteWorkObjectsRequest.getObjects() ) );
DeleteByQueryRequest deleteByQueryRequest = new DeleteByQueryRequest( index );
deleteByQueryRequest.setQuery( boolQueryBuilder );
return elasticClient.getClient()
.submitDeleteByQueryTask( deleteByQueryRequest, RequestOptions.DEFAULT )
.getTask();
Similar to DeleteByQueryRequest
, What is the request class we have to use to pass to elasticClient to get status of above deletion?
GetTaskRequest getTaskRequest = new GetTaskRequest(nodeandtaskid[0], Long.parseLong(nodeandtaskid[1]));
Optional<GetTaskResponse> response = elasticClient.getClient().tasks().get(getTaskRequest, RequestOptions.DEFAULT);
I was looking for GetTaskRequest. finally found it