Class AsyncResultsService<Task extends AsyncTask,Response extends AsyncResponse<Response>>

java.lang.Object
org.elasticsearch.xpack.core.async.AsyncResultsService<Task,Response>

public class AsyncResultsService<Task extends AsyncTask,Response extends AsyncResponse<Response>> extends Object
Service that is capable of retrieving and cleaning up AsyncTasks regardless of their state. It works with the TaskManager, if a task is still running and AsyncTaskIndexService if task results already stored there.
  • Constructor Details

    • AsyncResultsService

      public AsyncResultsService(AsyncTaskIndexService<Response> store, boolean updateInitialResultsInStore, Class<? extends Task> asyncTaskClass, TriFunction<Task,ActionListener<Response>,org.elasticsearch.core.TimeValue,Boolean> addCompletionListener, TaskManager taskManager, ClusterService clusterService)
      Creates async results service
      Parameters:
      store - AsyncTaskIndexService for the response we are working with
      updateInitialResultsInStore - true if initial results are stored (Async Search) or false otherwise (EQL Search)
      asyncTaskClass - async task class
      addCompletionListener - function that registers a completion listener with the task
      taskManager - task manager
      clusterService - cluster service
  • Method Details