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

Node.injector介绍

暂无

代码示例

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

public static Injector injector() {
  if ((instance.node != null) && (!instance.node.isClosed()))
    return instance.node.injector();
  return null;
}

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

private synchronized <T> T getInstanceFromNode(Class<T> clazz, Node node) {
  return node.injector().getInstance(clazz);
}

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

private static ClusterService getClusterService(Node node) {
  return node.injector().getInstance(ClusterService.class);
}

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

private static ClusterService getClusterService(Node node) {
  return node.injector().getInstance(ClusterService.class);
}

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

/**
 * Get an instance for a particular class using the injector of the singleton node.
 */
protected <T> T getInstanceFromNode(Class<T> clazz) {
  return ElassandraDaemon.instance.node().injector().getInstance(clazz);
}

代码示例来源：origin: codelibs/elasticsearch-cluster-runner

public synchronized <T> T getInstance(final Class<T> clazz) {
  final Node node = masterNode();
  return node.injector().getInstance(clazz);
}

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

public Client client(Node node, String clusterName) {
    TransportAddress addr = node.injector().getInstance(TransportService.class).boundAddress().publishAddress();
    Settings nodeSettings = node.settings();
    Builder builder = Settings.builder()
      .put("client.transport.nodes_sampler_interval", "1s")
      .put(Environment.PATH_HOME_SETTING.getKey(), baseDir)
      .put("node.name", TRANSPORT_CLIENT_PREFIX + node.settings().get("node.name"))
      .put(ClusterName.CLUSTER_NAME_SETTING.getKey(), clusterName).put("client.transport.sniff", sniff)
      .put("logger.prefix", nodeSettings.get("logger.prefix", ""))
      .put("logger.level", nodeSettings.get("logger.level", "INFO"))
      .put(settings);
    if (NetworkModule.TRANSPORT_TYPE_SETTING.exists(settings)) {
      builder.put(NetworkModule.TRANSPORT_TYPE_SETTING.getKey(), NetworkModule.TRANSPORT_TYPE_SETTING.get(settings));
    } else {
      builder.put(NetworkModule.TRANSPORT_TYPE_SETTING.getKey(), getTestTransportType());
    }
    TransportClient client = new MockTransportClient(builder.build(), plugins);
    client.addTransportAddress(addr);
    return client;
  }
}

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

public Callable<?> getInitializationTask() 
{
  return () -> {
    initCounter++;
    assert initCounter == 1 : "index initialized more than once";
    if (ElassandraDaemon.instance.node() != null) {
      logger.debug("Initializing elastic secondary index=[{}] hashCode={} initCounter={}", index_name, hashCode(), initCounter);
      // 2i index can be recycled by cassandra, while ES node restarted during tests, so update clusterService reference.
      clusterService = ElassandraDaemon.instance.node().injector().getInstance(ClusterService.class);
      clusterService.addListener(this);
      
      initMapping();
      
      // Avoid inter-bocking with Keyspace.open()->rebuild()->flush()->open().
      if (Keyspace.isInitialized() && !baseCfs.isEmpty() && !isBuilt())
        baseCfs.indexManager.buildIndexBlocking(this);
    } else {
      clusterService = null;
    }
    return null;
  };
}

代码示例来源：origin: harbby/presto-connectors

blockIndicesRead = settings.getAsArray("tribe.blocks.read.indices", Strings.EMPTY_ARRAY);
for (Node node : nodes) {
  node.injector().getInstance(ClusterService.class).add(new TribeClusterStateListener(node));