Module org.elasticsearch.xcore

Package org.elasticsearch.xpack.core.async

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

Constructors

Constructor	Description
AsyncResultsService(AsyncTaskIndexService<Response> store, boolean updateInitialResultsInStore, Class<? extends Task> asyncTaskClass, QuadFunction<Task,ActionListener<Response>,TimeValue,Boolean,Boolean> addCompletionListener, TaskManager taskManager, ClusterService clusterService)	Creates async results service

Method Summary

Modifier and Type	Method	Description
DiscoveryNode	getNode(String id)
boolean	isLocalNode(DiscoveryNode node)
void	retrieveResult(GetAsyncResultRequest request, ActionListener<Response> listener)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AsyncResultsService

public AsyncResultsService(AsyncTaskIndexService<Response> store,
 boolean updateInitialResultsInStore,
 Class<? extends Task> asyncTaskClass,
 QuadFunction<Task,ActionListener<Response>,TimeValue,Boolean,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

getNode

public DiscoveryNode getNode(String id)

isLocalNode

public boolean isLocalNode(DiscoveryNode node)

retrieveResult

public void retrieveResult(GetAsyncResultRequest request,
 ActionListener<Response> listener)