Module org.elasticsearch.xcore
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 Summary
ConstructorsConstructorDescriptionAsyncResultsService(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 -
Method Summary
Modifier and TypeMethodDescriptionbooleanisLocalNode(DiscoveryNode node) voidretrieveResult(GetAsyncResultRequest request, ActionListener<Response> listener)
-
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 withupdateInitialResultsInStore- true if initial results are stored (Async Search) or false otherwise (EQL Search)asyncTaskClass- async task classaddCompletionListener- function that registers a completion listener with the tasktaskManager- task managerclusterService- cluster service
-
-
Method Details
-
getNode
-
isLocalNode
-
retrieveResult
-