Java 类org.elasticsearch.action.search.TransportSearchAction 实例源码

AsyncAction(Task task, AddFeaturesToSetRequest request, ActionListener<AddFeaturesToSetResponse> listener,
                   ClusterService clusterService, TransportSearchAction searchAction, TransportGetAction getAction,
                   TransportFeatureStoreAction featureStoreAction) {
    this.task = task;
    this.listener = listener;
    this.featureSetName = request.getFeatureSet();
    this.featureNamesQuery = request.getFeatureNameQuery();
    this.features = request.getFeatures();
    if (featureNamesQuery != null) {
        assert features == null || features.isEmpty();
        // 2 async actions if we fetch features from store, one otherwize.
        this.countdown = new CountDown(2);
    } else {
        assert features != null && !features.isEmpty();
        // 1 async actions if we already have features.
        this.countdown = new CountDown(1);
    }
    this.merge = request.isMerge();
    this.store = request.getStore();
    this.routing = request.getRouting();
    this.clusterService = clusterService;
    this.searchAction = searchAction;
    this.getAction = getAction;
    this.featureStoreAction = featureStoreAction;
    this.validation = request.getValidation();
}

@Inject
public TransportClusteringAction(Settings settings,
                                 ThreadPool threadPool,
                                 TransportService transportService,
                                 TransportSearchAction searchAction,
                                 ControllerSingleton controllerSingleton,
                                 ActionFilters actionFilters,
                                 IndexNameExpressionResolver indexNameExpressionResolver,
                                 NamedXContentRegistry xContentRegistry) {
    super(settings,
          ClusteringAction.NAME,
          threadPool,
          actionFilters,
          indexNameExpressionResolver,
          transportService.getTaskManager());

    this.searchAction = searchAction;
    this.controllerSingleton = controllerSingleton;
    transportService.registerRequestHandler(
            ClusteringAction.NAME,
            ClusteringActionRequest::new,
            ThreadPool.Names.SAME,
            new TransportHandler());
}

@Inject
public TransportSearchTemplateAction(Settings settings, ThreadPool threadPool, TransportService transportService,
                                     ActionFilters actionFilters, IndexNameExpressionResolver resolver,
                                     ScriptService scriptService,
                                     TransportSearchAction searchAction,
                                     NamedXContentRegistry xContentRegistry) {
    super(settings, SearchTemplateAction.NAME, threadPool, transportService, actionFilters, resolver, SearchTemplateRequest::new);
    this.scriptService = scriptService;
    this.searchAction = searchAction;
    this.xContentRegistry = xContentRegistry;
}

@Inject
public TransportAddFeatureToSetAction(Settings settings, ThreadPool threadPool,
                                         TransportService transportService, ActionFilters actionFilters,
                                         IndexNameExpressionResolver indexNameExpressionResolver,
                                         ClusterService clusterService, TransportSearchAction searchAction,
                                         TransportGetAction getAction, TransportFeatureStoreAction featureStoreAction) {
    super(settings, AddFeaturesToSetAction.NAME, threadPool, transportService, actionFilters, indexNameExpressionResolver,
            AddFeaturesToSetRequest::new);
    this.clusterService = clusterService;
    this.searchAction = searchAction;
    this.getAction = getAction;
    this.featureStoreAction = featureStoreAction;
}

@Inject
public TransportCoordinateSearchAction(Settings settings, ThreadPool threadPool,
                                       TransportService transportService, FilterJoinCacheService cacheService,
                                       ActionFilters actionFilters, TransportSearchAction searchAction,
                                       IndexNameExpressionResolver indexNameExpressionResolver, Client client) {
  super(settings, CoordinateSearchAction.NAME, threadPool, transportService, actionFilters,
          indexNameExpressionResolver, client, SearchRequest.class);
  this.searchAction = searchAction;
  this.cacheService = cacheService;
}

@Inject
public TransportSearchScriptTemplateAction(final Settings settings, final ThreadPool threadPool,
        final TransportService transportService, final ActionFilters actionFilters, final IndexNameExpressionResolver resolver,
        final ScriptService scriptService, final TransportSearchAction searchAction, final NamedXContentRegistry xContentRegistry) {
    super(settings, SearchScriptTemplateAction.NAME, threadPool, transportService, actionFilters, resolver,
            SearchScriptTemplateRequest::new);
    this.scriptService = scriptService;
    this.searchAction = searchAction;
    this.xContentRegistry = xContentRegistry;
}

@Inject
public TransportPutWarmerAction(Settings settings, TransportService transportService, ClusterService clusterService, ThreadPool threadPool,
                                TransportSearchAction searchAction, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver) {
    super(settings, PutWarmerAction.NAME, transportService, clusterService, threadPool, actionFilters, indexNameExpressionResolver, PutWarmerRequest.class);
    this.searchAction = searchAction;
}