javaspring-bootelasticsearch

Retrieve a single task status elastic search


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?


Solution

  • 
    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