org.elasticsearch.node.Node类的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(10.9k)|赞(0)|评价(0)|浏览(199)

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

Node介绍

[英]A node represent a node within a cluster ( cluster.name). The #client() can be used in order to use a Client to perform actions/operations against the cluster.
[中]节点表示集群中的节点（cluster.name）。可以使用#client（）来使用客户端对集群执行操作。

代码示例

代码示例来源：origin: stagemonitor/stagemonitor

  1. private static void startElasticsearch() throws Exception {
  2.   try {
  3.     FileUtils.deleteDirectory(new File("build/elasticsearch"));
  4.   } catch (IOException e) {
  5.     // ignore
  6.   }
  7.   final Settings settings = Settings.builder()
  8.       .put("path.home", "build/elasticsearch")
  9.       .put("node.name", "junit-es-node")
  10.       .put("path.logs", "build/elasticsearch/logs")
  11.       .put("path.data", "build/elasticsearch/data")
  12.       .put("transport.type", "local")
  13.       .put("http.type", "netty4")
  14.       .build();
  15.   node = new TestNode(settings, Collections.singletonList(Netty4Plugin.class));
  16.   node.start();
  17.   node.client().admin().cluster().prepareHealth().setWaitForGreenStatus().get();
  18. }

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

  1. @Override
  2. public void close() throws BackendException {
  3.   if (node != null && !node.isClosed()) {
  4.     node.close();
  5.   }
  6.   client.close();
  7. }

代码示例来源：origin: Netflix/conductor

  1. private String getPort() {
  2.   return instance.settings().get("http.port");
  3. }

代码示例来源：origin: apache/flink

  1. @Override
  2.   public void cleanup() {
  3.     if (node != null && !node.isClosed()) {
  4.       node.close();
  5.       node = null;
  6.     }
  7.   }
  8. }

代码示例来源：origin: Netflix/conductor

  1. public synchronized void start(String clusterName, String host, int port) throws Exception {
  2.   if (instance != null) {
  3.     String msg = String.format(
  4.             "An instance of this Embedded Elastic Search server is already running on port: %d.  " +
  5.                 "It must be stopped before you can call start again.",
  6.             getPort()
  7.         );
  8.     logger.error(msg);
  9.     throw new IllegalStateException(msg);
  10.   }
  11.   final Settings settings = getSettings(clusterName, host, port);
  12.   dataDir = setupDataDir(settings.get(ElasticSearchConfiguration.EMBEDDED_DATA_PATH_DEFAULT_VALUE));
  13.   logger.info("Starting ElasticSearch for cluster {} ", settings.get("cluster.name"));
  14.   instance = new PluginConfigurableNode(settings, singletonList(Netty4Plugin.class));
  15.   instance.start();
  16.   Runtime.getRuntime().addShutdownHook(new Thread(() -> {
  17.     try {
  18.       if (instance != null) {
  19.         instance.close();
  20.       }
  21.     } catch (IOException e) {
  22.       logger.error("Error closing ElasticSearch");
  23.     }
  24.   }));
  25.   logger.info("ElasticSearch cluster {} started in local mode on port {}", instance.settings().get("cluster.name"), getPort());
  26. }

代码示例来源：origin: Impetus/Kundera

  1. @AfterClass
  2. public static void tearDownAfterClass() throws Exception
  3. {
  4.   node.close();
  5. }

代码示例来源：origin: brianfrankcooper/YCSB

  1. Builder settings = Settings.settingsBuilder()
  2.   .put("cluster.name", DEFAULT_CLUSTER_NAME)
  3.   .put("node.local", Boolean.toString(!remoteMode))
  4.   .put("path.home", pathHome);
  5.  node = nodeBuilder().clusterName(clusterName).settings(settings).node();
  6.  node.start();
  7.  client = node.client();
  8.     client.admin().indices()
  9.         .exists(Requests.indicesExistsRequest(indexKey)).actionGet()
  10.         .isExists();
  11. if (exists && newdb) {
  12.  client.admin().indices().prepareDelete(indexKey).execute().actionGet();
  13.  client.admin().indices().create(
  14.      new CreateIndexRequest(indexKey)
  15.          .settings(
  16.              Settings.builder()
  17.                  .put("index.number_of_shards", numberOfShards)
  18.                  .put("index.number_of_replicas", numberOfReplicas)

代码示例来源：origin: larsga/Duke

  1. NodeBuilder builder = NodeBuilder.nodeBuilder();
  2.   builder.settings(settings.build());
  3.   this.node = builder.client(this.clientOnly).local(this.local)
  4.       .node();
  5.   this.client = this.node.client();
  6. ClusterHealthResponse actionGet = this.client.admin().cluster()
  7.     .prepareHealth().setWaitForYellowStatus().execute().actionGet();
  8. System.out.println("ElasticSearch Health Check " + actionGet);

代码示例来源：origin: SonarSource/sonarqube

  1. private static void deleteIndexIfExists(String name) {
  2.  try {
  3.   DeleteIndexResponse response = SHARED_NODE.client().admin().indices().prepareDelete(name).get();
  4.   checkState(response.isAcknowledged(), "Fail to drop the index " + name);
  5.  } catch (IndexNotFoundException e) {
  6.   // ignore
  7.  }
  8. }

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

  1. @Test
  2. public void testIndexCreationOptions() throws InterruptedException, BackendException {
  3.   final int shards = 77;
  4.   ElasticsearchRunner esr = new ElasticsearchRunner(".", "indexCreationOptions.yml");
  5.   esr.start();
  6.   CommonsConfiguration cc = new CommonsConfiguration(new BaseConfiguration());
  7.   cc.set("index." + INDEX_NAME + ".elasticsearch.create.ext.number_of_shards", String.valueOf(shards));
  8.   cc.set("index." + INDEX_NAME + ".elasticsearch.ext.cluster.name", "indexCreationOptions");
  9.   ModifiableConfiguration config =
  10.       new ModifiableConfiguration(GraphDatabaseConfiguration.ROOT_NS,
  11.           cc, BasicConfiguration.Restriction.NONE);
  12.   config.set(INTERFACE, ElasticSearchSetup.NODE.toString(), INDEX_NAME);
  13.   Configuration indexConfig = config.restrictTo(INDEX_NAME);
  14.   IndexProvider idx = new ElasticSearchIndex(indexConfig);
  15.   simpleWriteAndQuery(idx);
  16.   ImmutableSettings.Builder settingsBuilder = ImmutableSettings.settingsBuilder();
  17.   settingsBuilder.put("discovery.zen.ping.multicast.enabled", "false");
  18.   settingsBuilder.put("discovery.zen.ping.unicast.hosts", "localhost,127.0.0.1:9300");
  19.   settingsBuilder.put("cluster.name", "indexCreationOptions");
  20.   NodeBuilder nodeBuilder = NodeBuilder.nodeBuilder().settings(settingsBuilder.build());
  21.   nodeBuilder.client(true).data(false).local(false);
  22.   Node n = nodeBuilder.build().start();
  23.   GetSettingsResponse response = n.client().admin().indices().getSettings(new GetSettingsRequest().indices("titan")).actionGet();
  24.   assertEquals(String.valueOf(shards), response.getSetting("titan", "index.number_of_shards"));
  25.   idx.close();
  26.   n.stop();
  27.   esr.stop();
  28. }

代码示例来源：origin: apache/metron

  1. Settings.Builder settingsBuilder = Settings.builder()
  2.   .put("cluster.name", "metron")
  3.   .put("path.logs",logDir.getAbsolutePath())
  4.   .put("path.data",dataDir.getAbsolutePath())
  5.   .put("path.home", indexDir.getAbsoluteFile())
  6.   .put("transport.type", "netty4")
  7. node = new TestNode(settingsBuilder.build(), asList(Netty4Plugin.class));
  8. client = node.client();
  9. try {
  10.  node.start();
  11. } catch (NodeValidationException e) {
  12.  throw new UnableToStartException("Error starting ES node.", e);
  13.    client.admin().indices().prepareCreate(m.index)
  14.     .addMapping(m.docType, m.mapping).get();

代码示例来源：origin: ff4j/ff4j

  1. private void initNativeClient() {
  2.   esClient = NodeBuilder.nodeBuilder().client(true).node().client();
  3.   boolean indexExists = esClient.admin().indices().prepareExists(indexName).execute().actionGet().isExists();
  4.   if (indexExists) {
  5.     esClient.admin().indices().prepareDelete(indexName).execute().actionGet();
  6.   }
  7.   esClient.admin().indices().prepareCreate(indexName).execute().actionGet();
  8. }

代码示例来源：origin: apache/flume

  1. private void openLocalDiscoveryClient() {
  2.  logger.info("Using ElasticSearch AutoDiscovery mode");
  3.  Node node = NodeBuilder.nodeBuilder().client(true).local(true).node();
  4.  if (client != null) {
  5.   client.close();
  6.  }
  7.  client = node.client();
  8. }

代码示例来源：origin: apache/flink

  1. .build();
  2. node = nodeBuilder()
  3.   .settings(settings)
  4.   .client(true)
  5.   .data(false)
  6.   .node();
  7. Client client = node.client();

代码示例来源：origin: loklak/loklak_server

  1. /**
  2.  * create a elasticsearch node client (embedded elasticsearch)
  3.  * @param settings
  4.  */
  5. public ElasticsearchClient(final Settings.Builder settings) {
  6.   // create a node
  7.   this.elasticsearchNode = NodeBuilder.nodeBuilder().local(false).settings(settings).node();
  8.   // create a client
  9.   this.elasticsearchClient = elasticsearchNode.client();
  10. }

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

  1. @Override
  2.   public Connection connect(Configuration config) throws IOException {
  3.     log.debug("Configuring Node Client");
  4.     ImmutableSettings.Builder settingsBuilder = settingsBuilder(config);
  5.     if (config.has(ElasticSearchIndex.TTL_INTERVAL)) {
  6.       String k = "indices.ttl.interval";
  7.       settingsBuilder.put(k, config.get(ElasticSearchIndex.TTL_INTERVAL));
  8.       log.debug("Set {}: {}", k, config.get(ElasticSearchIndex.TTL_INTERVAL));
  9.     }
  10.     makeLocalDirsIfNecessary(settingsBuilder, config);
  11.     NodeBuilder nodeBuilder = NodeBuilder.nodeBuilder().settings(settingsBuilder.build());
  12.     // Apply explicit Titan properties file overrides (otherwise conf-file or ES defaults apply)
  13.     if (config.has(ElasticSearchIndex.CLIENT_ONLY)) {
  14.       boolean clientOnly = config.get(ElasticSearchIndex.CLIENT_ONLY);
  15.       nodeBuilder.client(clientOnly).data(!clientOnly);
  16.     }
  17.     if (config.has(ElasticSearchIndex.LOCAL_MODE))
  18.       nodeBuilder.local(config.get(ElasticSearchIndex.LOCAL_MODE));
  19.     if (config.has(ElasticSearchIndex.LOAD_DEFAULT_NODE_SETTINGS))
  20.       nodeBuilder.loadConfigSettings(config.get(ElasticSearchIndex.LOAD_DEFAULT_NODE_SETTINGS));
  21.     Node node = nodeBuilder.node();
  22.     Client client = node.client();
  23.     return new Connection(node, client);
  24.   }
  25. };

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

  1. boolean local = config.get(LOCAL_MODE);
  2. NodeBuilder builder = NodeBuilder.nodeBuilder();
  3. Preconditions.checkArgument(config.has(INDEX_CONF_FILE) || config.has(INDEX_DIRECTORY),
  4.     "Must either configure configuration file or base directory");
  5.     fis = new FileInputStream(configFile);
  6.     sb.loadFromStream(configFile, fis);
  7.     builder.settings(sb.build());
  8.   } catch (FileNotFoundException e) {
  9.     throw new TitanException(e);
  10.   b.put("indices.ttl.interval", "5s");
  11.   builder.settings(b.build());
  12. node = builder.client(clientOnly).data(!clientOnly).local(local).node();
  13. client = node.client();

代码示例来源：origin: floragunncom/search-guard

  1. Client client = node.client();
  2. try {
  3.   log.debug("waiting for cluster state {} and {} nodes", status.name(), expectedNodeCount);
  4.   final ClusterHealthResponse healthResponse = client.admin().cluster().prepareHealth()
  5.       .setWaitForStatus(status).setTimeout(timeout).setMasterNodeTimeout(timeout).setWaitForNodes("" + expectedNodeCount).execute()
  6.       .actionGet();
  7.   final NodesInfoResponse res = client.admin().cluster().nodesInfo(new NodesInfoRequest()).actionGet();

代码示例来源：origin: org.n52.iceland/statistics

  1. /**
  2.  * Starts client mode in local Node mode.
  3.  */
  4. private void initNodeMode() {
  5.   Objects.requireNonNull(settings.getClusterName());
  6.   Objects.requireNonNull(settings.getClusterNodes());
  7.   Settings.Builder settingsBuilder = Settings.settingsBuilder();
  8.   settingsBuilder.put("discovery.zen.ping.unicast.hosts", Joiner.on(",").join(settings.getClusterNodes()));
  9.   node = NodeBuilder.nodeBuilder().settings(settingsBuilder)
  10.       .client(true)
  11.       .clusterName(settings.getClusterName())
  12.       .node();
  13.   client = node.client();
  14.   logger.info("ElasticSearch data handler starting in LAN mode");
  15. }

代码示例来源：origin: apache/storm

  1. /**
  2.  * Starts an ElasticSearch node.
  3.  * @return the started node.
  4.  */
  5. public static Node startEsNode() {
  6.   Node node = NodeBuilder.nodeBuilder().data(true).settings(
  7.       Settings.settingsBuilder()
  8.           .put(ClusterName.SETTING, EsConstants.CLUSTER_NAME)
  9.           .put(IndexMetaData.SETTING_NUMBER_OF_SHARDS, 1)
  10.           .put(IndexMetaData.SETTING_NUMBER_OF_REPLICAS, 0)
  11.           .put(EsExecutors.PROCESSORS, 1)
  12.           .put("http.enabled", true)
  13.           .put("index.percolator.map_unmapped_fields_as_string",
  14.               true)
  15.           .put("index.store.type", "mmapfs")
  16.           .put("path.home", "./data")
  17.   ).build();
  18.   node.start();
  19.   return node;
  20. }

内容来源于网络，如有侵权，请联系作者删除！

Node

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com