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

Node.stop介绍

暂无

代码示例

代码示例来源：origin: thinkaurelius/titan

@Test
public void testIndexCreationOptions() throws InterruptedException, BackendException {
  final int shards = 77;
  ElasticsearchRunner esr = new ElasticsearchRunner(".", "indexCreationOptions.yml");
  esr.start();
  CommonsConfiguration cc = new CommonsConfiguration(new BaseConfiguration());
  cc.set("index." + INDEX_NAME + ".elasticsearch.create.ext.number_of_shards", String.valueOf(shards));
  cc.set("index." + INDEX_NAME + ".elasticsearch.ext.cluster.name", "indexCreationOptions");
  ModifiableConfiguration config =
      new ModifiableConfiguration(GraphDatabaseConfiguration.ROOT_NS,
          cc, BasicConfiguration.Restriction.NONE);
  config.set(INTERFACE, ElasticSearchSetup.NODE.toString(), INDEX_NAME);
  Configuration indexConfig = config.restrictTo(INDEX_NAME);
  IndexProvider idx = new ElasticSearchIndex(indexConfig);
  simpleWriteAndQuery(idx);
  ImmutableSettings.Builder settingsBuilder = ImmutableSettings.settingsBuilder();
  settingsBuilder.put("discovery.zen.ping.multicast.enabled", "false");
  settingsBuilder.put("discovery.zen.ping.unicast.hosts", "localhost,127.0.0.1:9300");
  settingsBuilder.put("cluster.name", "indexCreationOptions");
  NodeBuilder nodeBuilder = NodeBuilder.nodeBuilder().settings(settingsBuilder.build());
  nodeBuilder.client(true).data(false).local(false);
  Node n = nodeBuilder.build().start();
  GetSettingsResponse response = n.client().admin().indices().getSettings(new GetSettingsRequest().indices("titan")).actionGet();
  assertEquals(String.valueOf(shards), response.getSetting("titan", "index.number_of_shards"));
  idx.close();
  n.stop();
  esr.stop();
}

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

@Override
public synchronized void close() throws IOException {
  if (lifecycle.started()) {
    stop();

代码示例来源：origin: io.fabric8.insight/insight-elasticsearch-factory

@Override
public Node stop() {
  return nodeDelegate.stop();
}

代码示例来源：origin: jboss-fuse/fabric8

@Override
public Node stop() {
  return nodeDelegate.stop();
}

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

/**
 * hook for JSVC
 */
@Override
public void stop() {
  super.stop();
  if (node != null)
    node.stop();
}

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

@Override
public void shutdown() {
  client.close();
  if (inProcessNode != null) {
    inProcessNode.stop();
    inProcessNode = null;
  }
  if (propertyNameVisibilitiesStore instanceof Closeable) {
    try {
      ((Closeable) propertyNameVisibilitiesStore).close();
    } catch (IOException e) {
      Throwables.propagate(e);
    }
  }
}

代码示例来源：origin: stackoverflow.com

BasicConfigurator.configure();
 Node node = NodeBuilder.nodeBuilder().local(true).node();
 node.start();
 while (!node.isClosed()) {
   try {
     Thread.sleep(60*1000);
   } catch (InterruptedException e) {
     node.close();
   }
 }
 node.stop();

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

private static void stopNode() throws IOException {
  if (ElassandraDaemon.instance != null) {
    Node node = ElassandraDaemon.instance.node();
    if (node != null)
      node.stop();
    ElassandraDaemon.instance.node(null);
    IOUtils.close(node);
  }
}

代码示例来源：origin: stackoverflow.com

elasticSearchNode.stop();
elasticSearchNode.close();

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

@Override
public synchronized void close() throws IOException {
  if (lifecycle.started()) {
    stop();

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

@Override
public synchronized void close() throws IOException {
  if (lifecycle.started()) {
    stop();

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

toClose.add(() -> stopWatch.stop().start("plugin(" + plugin.getClass().getName() + ")"));
  toClose.add(plugin);
toClose.add(() -> stopWatch.stop().start("script"));
toClose.add(injector.getInstance(ScriptService.class));
toClose.add(() -> stopWatch.stop().start("thread_pool"));

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

@Override
public synchronized void close() {
  if (lifecycle.started()) {
    stop();