本文整理了Java中org.elasticsearch.transport.TransportService.sendChildRequest()方法的一些代码示例，展示了TransportService.sendChildRequest()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。TransportService.sendChildRequest()方法的具体详情如下：
包路径：org.elasticsearch.transport.TransportService
类名称：TransportService
方法名：sendChildRequest

TransportService.sendChildRequest介绍

暂无

代码示例

代码示例来源：origin: org.elasticsearch/elasticsearch

public final <T extends TransportResponse> void sendChildRequest(final DiscoveryNode node, final String action,
                                 final TransportRequest request, final Task parentTask,
                                 final TransportRequestOptions options,
                                 final TransportResponseHandler<T> handler) {
  try {
    Transport.Connection connection = getConnection(node);
    sendChildRequest(connection, action, request, parentTask, options, handler);
  } catch (NodeNotConnectedException ex) {
    // the caller might not handle this so we invoke the handler
    handler.handleException(ex);
  }
}

代码示例来源：origin: org.elasticsearch/elasticsearch

public void sendExecuteDfs(Transport.Connection connection, final ShardSearchTransportRequest request, SearchTask task,
              final SearchActionListener<DfsSearchResult> listener) {
  transportService.sendChildRequest(connection, DFS_ACTION_NAME, request, task,
      new ConnectionCountingHandler<>(listener, DfsSearchResult::new, clientConnections, connection.getNode().getId()));
}

代码示例来源：origin: org.elasticsearch/elasticsearch

public void sendExecuteQuery(Transport.Connection connection, final QuerySearchRequest request, SearchTask task,
               final SearchActionListener<QuerySearchResult> listener) {
  transportService.sendChildRequest(connection, QUERY_ID_ACTION_NAME, request, task,
      new ConnectionCountingHandler<>(listener, QuerySearchResult::new, clientConnections, connection.getNode().getId()));
}

代码示例来源：origin: org.elasticsearch/elasticsearch

public void sendExecuteScrollQuery(Transport.Connection connection, final InternalScrollSearchRequest request, SearchTask task,
                  final SearchActionListener<ScrollQuerySearchResult> listener) {
  transportService.sendChildRequest(connection, QUERY_SCROLL_ACTION_NAME, request, task,
      new ConnectionCountingHandler<>(listener, ScrollQuerySearchResult::new, clientConnections, connection.getNode().getId()));
}

代码示例来源：origin: org.elasticsearch/elasticsearch

public void sendExecuteQuery(Transport.Connection connection, final ShardSearchTransportRequest request, SearchTask task,
               final SearchActionListener<SearchPhaseResult> listener) {
  // we optimize this and expect a QueryFetchSearchResult if we only have a single shard in the search request
  // this used to be the QUERY_AND_FETCH which doesn't exist anymore.
  final boolean fetchDocuments = request.numberOfShards() == 1;
  Writeable.Reader<SearchPhaseResult> reader = fetchDocuments ? QueryFetchSearchResult::new : QuerySearchResult::new;
  final ActionListener handler = responseWrapper.apply(connection, listener);
  transportService.sendChildRequest(connection, QUERY_ACTION_NAME, request, task,
      new ConnectionCountingHandler<>(handler, reader, clientConnections, connection.getNode().getId()));
}

代码示例来源：origin: org.elasticsearch/elasticsearch

public void sendExecuteScrollFetch(Transport.Connection connection, final InternalScrollSearchRequest request, SearchTask task,
                  final SearchActionListener<ScrollQueryFetchSearchResult> listener) {
  transportService.sendChildRequest(connection, QUERY_FETCH_SCROLL_ACTION_NAME, request, task,
      new ConnectionCountingHandler<>(listener, ScrollQueryFetchSearchResult::new, clientConnections,
        connection.getNode().getId()));
}

代码示例来源：origin: org.elasticsearch/elasticsearch

private void sendExecuteFetch(Transport.Connection connection, String action, final ShardFetchRequest request, SearchTask task,
               final SearchActionListener<FetchSearchResult> listener) {
  transportService.sendChildRequest(connection, action, request, task,
      new ConnectionCountingHandler<>(listener, FetchSearchResult::new, clientConnections, connection.getNode().getId()));
}

代码示例来源：origin: org.elasticsearch/elasticsearch

public void sendCanMatch(Transport.Connection connection, final ShardSearchTransportRequest request, SearchTask task, final
            ActionListener<CanMatchResponse> listener) {
  if (connection.getNode().getVersion().onOrAfter(Version.V_5_6_0)) {
    transportService.sendChildRequest(connection, QUERY_CAN_MATCH_NAME, request, task,
      TransportRequestOptions.EMPTY, new ActionListenerResponseHandler<>(listener, CanMatchResponse::new));
  } else {
    // this might look weird but if we are in a CrossClusterSearch environment we can get a connection
    // to a pre 5.latest node which is proxied by a 5.latest node under the hood since we are only compatible with 5.latest
    // instead of sending the request we shortcut it here and let the caller deal with this -- see #25704
    // also failing the request instead of returning a fake answer might trigger a retry on a replica which might be on a
    // compatible node
    throw new IllegalArgumentException("can_match is not supported on pre 5.6 nodes");
  }
}

代码示例来源：origin: org.elasticsearch/elasticsearch

ActionListener<ResyncReplicationResponse> listener) {
transportService.sendChildRequest(
  clusterService.localNode(),
  transportPrimaryAction,

代码示例来源：origin: org.elasticsearch/elasticsearch

/**
 * Used by {@link TransportSearchAction} to send the expand queries (field collapsing).
 */
void sendExecuteMultiSearch(final MultiSearchRequest request, SearchTask task,
              final ActionListener<MultiSearchResponse> listener) {
  final Transport.Connection connection = transportService.getConnection(transportService.getLocalNode());
  transportService.sendChildRequest(connection, MultiSearchAction.NAME, request, task,
      new ConnectionCountingHandler<>(listener, MultiSearchResponse::new, clientConnections, connection.getNode().getId()));
}

代码示例来源：origin: org.elasticsearch/elasticsearch

public <T extends TransportResponse> void sendChildRequest(final Transport.Connection connection, final String action,
                              final TransportRequest request, final Task parentTask,
                              final TransportRequestOptions options,
                              final TransportResponseHandler<T> handler) {
  request.setParentTask(localNode.getId(), parentTask.getId());
  try {
    sendRequest(connection, action, request, options, handler);
  } catch (TaskCancelledException ex) {
    // The parent task is already cancelled - just fail the request
    handler.handleException(new TransportException(ex));
  } catch (NodeNotConnectedException ex) {
    // the caller might not handle this so we invoke the handler
    handler.handleException(ex);
  }
}

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

public void sendExecuteDfs(Transport.Connection connection, final ShardSearchTransportRequest request, SearchTask task,
              final SearchActionListener<DfsSearchResult> listener) {
  transportService.sendChildRequest(connection, DFS_ACTION_NAME, request, task,
    new ActionListenerResponseHandler<>(listener, DfsSearchResult::new));
}

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

private void sendExecuteFetch(Transport.Connection connection, String action, final ShardFetchRequest request, SearchTask task,
               final SearchActionListener<FetchSearchResult> listener) {
  transportService.sendChildRequest(connection, action, request, task,
    new ActionListenerResponseHandler<>(listener, FetchSearchResult::new));
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

public void sendExecuteQuery(Transport.Connection connection, final QuerySearchRequest request, SearchTask task,
               final SearchActionListener<QuerySearchResult> listener) {
  transportService.sendChildRequest(connection, QUERY_ID_ACTION_NAME, request, task,
      new ConnectionCountingHandler<>(listener, QuerySearchResult::new, clientConnections, connection.getNode().getId()));
}

代码示例来源：origin: apache/servicemix-bundles

public void sendExecuteQuery(Transport.Connection connection, final ShardSearchTransportRequest request, SearchTask task,
               final SearchActionListener<SearchPhaseResult> listener) {
  // we optimize this and expect a QueryFetchSearchResult if we only have a single shard in the search request
  // this used to be the QUERY_AND_FETCH which doesn't exist anymore.
  final boolean fetchDocuments = request.numberOfShards() == 1;
  Supplier<SearchPhaseResult> supplier = fetchDocuments ? QueryFetchSearchResult::new : QuerySearchResult::new;
  final ActionListener handler = responseWrapper.apply(connection, listener);
  transportService.sendChildRequest(connection, QUERY_ACTION_NAME, request, task,
      new ConnectionCountingHandler<>(handler, supplier, clientConnections, connection.getNode().getId()));
}

代码示例来源：origin: apache/servicemix-bundles

public void sendExecuteQuery(Transport.Connection connection, final QuerySearchRequest request, SearchTask task,
               final SearchActionListener<QuerySearchResult> listener) {
  transportService.sendChildRequest(connection, QUERY_ID_ACTION_NAME, request, task,
      new ConnectionCountingHandler<>(listener, QuerySearchResult::new, clientConnections, connection.getNode().getId()));
}

代码示例来源：origin: apache/servicemix-bundles

private void sendExecuteFetch(Transport.Connection connection, String action, final ShardFetchRequest request, SearchTask task,
               final SearchActionListener<FetchSearchResult> listener) {
  transportService.sendChildRequest(connection, action, request, task,
      new ConnectionCountingHandler<>(listener, FetchSearchResult::new, clientConnections, connection.getNode().getId()));
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

public void sendExecuteQuery(Transport.Connection connection, final ShardSearchTransportRequest request, SearchTask task,
               final SearchActionListener<SearchPhaseResult> listener) {
  // we optimize this and expect a QueryFetchSearchResult if we only have a single shard in the search request
  // this used to be the QUERY_AND_FETCH which doesn't exist anymore.
  final boolean fetchDocuments = request.numberOfShards() == 1;
  Supplier<SearchPhaseResult> supplier = fetchDocuments ? QueryFetchSearchResult::new : QuerySearchResult::new;
  final ActionListener handler = responseWrapper.apply(connection, listener);
  transportService.sendChildRequest(connection, QUERY_ACTION_NAME, request, task,
      new ConnectionCountingHandler<>(handler, supplier, clientConnections, connection.getNode().getId()));
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

private void sendExecuteFetch(Transport.Connection connection, String action, final ShardFetchRequest request, SearchTask task,
               final SearchActionListener<FetchSearchResult> listener) {
  transportService.sendChildRequest(connection, action, request, task,
      new ConnectionCountingHandler<>(listener, FetchSearchResult::new, clientConnections, connection.getNode().getId()));
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

/**
 * Used by {@link TransportSearchAction} to send the expand queries (field collapsing).
 */
void sendExecuteMultiSearch(final MultiSearchRequest request, SearchTask task,
              final ActionListener<MultiSearchResponse> listener) {
  final Transport.Connection connection = transportService.getConnection(transportService.getLocalNode());
  transportService.sendChildRequest(connection, MultiSearchAction.NAME, request, task,
      new ConnectionCountingHandler<>(listener, MultiSearchResponse::new, clientConnections, connection.getNode().getId()));
}