org.elasticsearch.node.Node.settings()方法的使用及代码示例

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

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

Node.settings介绍

[英]The settings that are used by this node. Contains original settings as well as additional settings provided by plugins.
[中]此节点使用的设置。包含原始设置以及插件提供的附加设置。

代码示例

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

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

代码示例来源：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: thinkaurelius/titan

  1. @Test
  2. public void testConfigurationFile() throws BackendException {
  3.   final String index = "es";
  4.   ModifiableConfiguration config = GraphDatabaseConfiguration.buildGraphConfiguration();
  5.   config.set(LOCAL_MODE, true, index);
  6.   config.set(CLIENT_ONLY, true, index);
  7.   config.set(INDEX_CONF_FILE, Joiner.on(File.separator).join("target", "test-classes", "es_nodename_foo.yml"), index);
  8.   config.set(GraphDatabaseConfiguration.INDEX_DIRECTORY, StorageSetup.getHomeDir("es"), index);
  9.   Configuration indexConfig = config.restrictTo(index);
  10.   ElasticSearchIndex idx = new ElasticSearchIndex(indexConfig); // Shouldn't throw exception
  11.   idx.close();
  12.   assertEquals("foo", idx.getNode().settings().get("node.name"));
  13.   config = GraphDatabaseConfiguration.buildGraphConfiguration();
  14.   config.set(LOCAL_MODE, true, index);
  15.   config.set(CLIENT_ONLY, true, index);
  16.   config.set(INDEX_CONF_FILE, Joiner.on(File.separator).join("target", "test-classes", "es_nodename_bar.yml"), index);
  17.   config.set(GraphDatabaseConfiguration.INDEX_DIRECTORY, StorageSetup.getHomeDir("es"), index);
  18.   indexConfig = config.restrictTo(index);
  19.   idx = new ElasticSearchIndex(indexConfig); // Shouldn't throw exception
  20.   idx.close();
  21.   assertEquals("bar", idx.getNode().settings().get("node.name"));
  22. }

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

  1. @Override
  2. public Settings settings() {
  3.   return nodeDelegate.settings();
  4. }

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

  1. @Override
  2. public Settings settings() {
  3.   return nodeDelegate.settings();
  4. }

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

  1. public void unbindNode(Node node) {
  2.     String clusterName = node.settings().get("cluster.name");
  3.     Set<Node> nodeSet = nodesClusterMap.get(clusterName);
  4.     if (nodeSet != null) {
  5.       nodeSet.remove(node);
  6.       if (nodeSet.isEmpty()) {
  7.         nodesClusterMap.remove(clusterName);
  8.       }
  9.     }
  10.   }
  11. }

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

  1. public void bindNode(Node node) {
  2.   String clusterName = node.settings().get("cluster.name");
  3.   Set<Node> nodeSet = nodesClusterMap.get(clusterName);
  4.   if (nodeSet == null) {
  5.     nodeSet = new HashSet<Node>();
  6.     nodesClusterMap.put(clusterName, nodeSet);
  7.   }
  8.   nodeSet.add(node);
  9. }

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

  1. public void unbindNode(Node node) {
  2.     String clusterName = node.settings().get("cluster.name");
  3.     Set<Node> nodeSet = nodesClusterMap.get(clusterName);
  4.     if (nodeSet != null) {
  5.       nodeSet.remove(node);
  6.       if (nodeSet.isEmpty()) {
  7.         nodesClusterMap.remove(clusterName);
  8.       }
  9.     }
  10.   }
  11. }

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

  1. public void bindNode(Node node) {
  2.   String clusterName = node.settings().get("cluster.name");
  3.   Set<Node> nodeSet = nodesClusterMap.get(clusterName);
  4.   if (nodeSet == null) {
  5.     nodeSet = new HashSet<Node>();
  6.     nodesClusterMap.put(clusterName, nodeSet);
  7.   }
  8.   nodeSet.add(node);
  9. }

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

  1. protected static String getUrl(final Node node, final String path) {
  2.   final StringBuilder urlBuf = new StringBuilder(200);
  3.   urlBuf.append("http://localhost:").append(node.settings().get("http.port"));
  4.   if (path.startsWith("/")) {
  5.     urlBuf.append(path);
  6.   } else {
  7.     urlBuf.append('/').append(path);
  8.   }
  9.   return urlBuf.toString();
  10. }

代码示例来源：origin: javanna/elasticshell

  1. @Override
  2.   public String toString() {
  3.     String nodeName = node.settings().get("name");
  4.     String clusterName = node.settings().get("cluster.name");
  5.     boolean local = Boolean.valueOf(node.settings().get("node.local"));
  6.     String prefix;
  7.     if (local) {
  8.       prefix = "Local node";
  9.     } else {
  10.       prefix = "Node";
  11.     }
  12.     return String.format("%s [%s] - cluster [%s]", prefix, nodeName, clusterName);
  13.   }
  14. }

代码示例来源：origin: Qihoo360/Quicksql

  1. @Override public void close() throws Exception {
  2.  node.close();
  3.  // cleanup data dirs
  4.  for (String name: Arrays.asList("path.data", "path.home")) {
  5.   if (node.settings().get(name) != null) {
  6.    File file = new File(node.settings().get(name));
  7.    if (file.exists()) {
  8.     file.delete();
  9.    }
  10.   }
  11.  }
  12. }

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

  1. private int getMasterNodesCount() {
  2.   return (int)nodes.values().stream().filter(n -> Node.NODE_MASTER_SETTING.get(n.node().settings())).count();
  3. }

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

  1. TribeClusterStateListener(Node tribeNode) {
  2.   String tribeName = TRIBE_NAME_SETTING.get(tribeNode.settings());
  3.   this.tribeName = tribeName;
  4.   executor = new TribeNodeClusterStateTaskExecutor(tribeName);
  5. }

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

  1. TribeClusterStateListener(Node tribeNode) {
  2.   String tribeName = TRIBE_NAME_SETTING.get(tribeNode.settings());
  3.   this.tribeName = tribeName;
  4.   executor = new TribeNodeClusterStateTaskExecutor(tribeName);
  5. }

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

  1. TribeClusterStateListener(Node tribeNode) {
  2.   String tribeName = tribeNode.settings().get(TRIBE_NAME);
  3.   this.tribeName = tribeName;
  4.   executor = new TribeNodeClusterStateTaskExecutor(tribeName);
  5. }

代码示例来源：origin: infochimps-labs/wonderdog

  1. /**
  2.   Start an embedded Elasticsearch node.
  3.   The node will not store any data locally (non-datanode) but
  4.   will connect to a cluster using the default Elasticsearch
  5.   settings (those available in
  6.   /etc/elasticsearch/elasticsearch.yml).
  7. */
  8. private void startNode() {
  9. LOG.info("Starting embedded Elasticsearch client (non-datanode)...");
  10. this.node   = NodeBuilder.nodeBuilder().client(true).node();
  11. LOG.info("Successfully joined Elasticsearch cluster '"+ClusterName.clusterNameFromSettings(node.settings())+'"');
  12. }

代码示例来源：origin: infochimps-labs/wonderdog

  1. /**
  2.   Start an embedded Elasticsearch node.
  3.   The node will not store any data locally (non-datanode) but
  4.   will connect to a cluster using the default Elasticsearch
  5.   settings (those available in
  6.   /etc/elasticsearch/elasticsearch.yml).
  7. */
  8. private void startNode() {
  9. LOG.info("Starting embedded Elasticsearch client (non-datanode)...");
  10. this.node   = NodeBuilder.nodeBuilder().client(true).node();
  11. LOG.info("Successfully joined Elasticsearch cluster '"+ClusterName.clusterNameFromSettings(node.settings())+'"');
  12. }

代码示例来源：origin: Qihoo360/Quicksql

  1. @Override public void close() throws Exception {
  2.  node.close();
  3.  // cleanup data dirs
  4.  for (String name: Arrays.asList("path.data", "path.home")) {
  5.   if (node.settings().get(name) != null) {
  6.    File file = new File(node.settings().get(name));
  7.    if (file.exists()) {
  8.     file.delete();
  9.    }
  10.   }
  11.  }
  12. }

代码示例来源：origin: Qihoo360/Quicksql

  1. @Override
  2. public void close() throws Exception {
  3.   node.close();
  4.   // cleanup data dirs
  5.   for (String name : Arrays.asList("path.data", "path.home")) {
  6.     if (node.settings().get(name) != null) {
  7.       File file = new File(node.settings().get(name));
  8.       if (file.exists()) {
  9.         file.delete();
  10.       }
  11.     }
  12.   }
  13. }

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

Node

相关文章

    查看更多

    热门标签

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

    最新文章

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