Module org.elasticsearch.server
Class TransportFetchPhaseCoordinationAction
java.lang.Object
org.elasticsearch.action.support.TransportAction<TransportFetchPhaseCoordinationAction.Request,TransportFetchPhaseCoordinationAction.Response>
org.elasticsearch.action.support.HandledTransportAction<TransportFetchPhaseCoordinationAction.Request,TransportFetchPhaseCoordinationAction.Response>
org.elasticsearch.search.fetch.chunk.TransportFetchPhaseCoordinationAction
public class TransportFetchPhaseCoordinationAction
extends HandledTransportAction<TransportFetchPhaseCoordinationAction.Request,TransportFetchPhaseCoordinationAction.Response>
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classstatic class -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final TransportVersionstatic final TransportVersionstatic final ActionType<TransportFetchPhaseCoordinationAction.Response> Fields inherited from class org.elasticsearch.action.support.TransportAction
actionName, logger, taskManager -
Constructor Summary
ConstructorsConstructorDescriptionTransportFetchPhaseCoordinationAction(TransportService transportService, ActionFilters actionFilters, ActiveFetchPhaseTasks activeFetchPhaseTasks, CircuitBreakerService circuitBreakerService, NamedWriteableRegistry namedWriteableRegistry) -
Method Summary
Modifier and TypeMethodDescriptionvoiddoExecute(Task task, TransportFetchPhaseCoordinationAction.Request request, ActionListener<TransportFetchPhaseCoordinationAction.Response> listener) Methods inherited from class org.elasticsearch.action.support.TransportAction
execute, executeDirect, localOnly
-
Field Details
-
TYPE
-
CHUNKED_FETCH_PHASE
-
CHUNKED_FETCH_DOC_ID_ORDER
-
-
Constructor Details
-
TransportFetchPhaseCoordinationAction
@Inject public TransportFetchPhaseCoordinationAction(TransportService transportService, ActionFilters actionFilters, ActiveFetchPhaseTasks activeFetchPhaseTasks, CircuitBreakerService circuitBreakerService, NamedWriteableRegistry namedWriteableRegistry)
-
-
Method Details
-
doExecute
public void doExecute(Task task, TransportFetchPhaseCoordinationAction.Request request, ActionListener<TransportFetchPhaseCoordinationAction.Response> listener)
-