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

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

本文整理了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

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

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

public synchronized void start(String clusterName, String host, int port) throws Exception {
  if (instance != null) {
    String msg = String.format(
            "An instance of this Embedded Elastic Search server is already running on port: %d.  " +
                "It must be stopped before you can call start again.",
            getPort()
        );
    logger.error(msg);
    throw new IllegalStateException(msg);
  }
  final Settings settings = getSettings(clusterName, host, port);
  dataDir = setupDataDir(settings.get(ElasticSearchConfiguration.EMBEDDED_DATA_PATH_DEFAULT_VALUE));
  logger.info("Starting ElasticSearch for cluster {} ", settings.get("cluster.name"));
  instance = new PluginConfigurableNode(settings, singletonList(Netty4Plugin.class));
  instance.start();
  Runtime.getRuntime().addShutdownHook(new Thread(() -> {
    try {
      if (instance != null) {
        instance.close();
      }
    } catch (IOException e) {
      logger.error("Error closing ElasticSearch");
    }
  }));
  logger.info("ElasticSearch cluster {} started in local mode on port {}", instance.settings().get("cluster.name"), getPort());
}

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

@Test
public void testConfigurationFile() throws BackendException {
  final String index = "es";
  ModifiableConfiguration config = GraphDatabaseConfiguration.buildGraphConfiguration();
  config.set(LOCAL_MODE, true, index);
  config.set(CLIENT_ONLY, true, index);
  config.set(INDEX_CONF_FILE, Joiner.on(File.separator).join("target", "test-classes", "es_nodename_foo.yml"), index);
  config.set(GraphDatabaseConfiguration.INDEX_DIRECTORY, StorageSetup.getHomeDir("es"), index);
  Configuration indexConfig = config.restrictTo(index);
  ElasticSearchIndex idx = new ElasticSearchIndex(indexConfig); // Shouldn't throw exception
  idx.close();
  assertEquals("foo", idx.getNode().settings().get("node.name"));
  config = GraphDatabaseConfiguration.buildGraphConfiguration();
  config.set(LOCAL_MODE, true, index);
  config.set(CLIENT_ONLY, true, index);
  config.set(INDEX_CONF_FILE, Joiner.on(File.separator).join("target", "test-classes", "es_nodename_bar.yml"), index);
  config.set(GraphDatabaseConfiguration.INDEX_DIRECTORY, StorageSetup.getHomeDir("es"), index);
  indexConfig = config.restrictTo(index);
  idx = new ElasticSearchIndex(indexConfig); // Shouldn't throw exception
  idx.close();
  assertEquals("bar", idx.getNode().settings().get("node.name"));
}

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

@Override
public Settings settings() {
  return nodeDelegate.settings();
}

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

@Override
public Settings settings() {
  return nodeDelegate.settings();
}

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

public void unbindNode(Node node) {
    String clusterName = node.settings().get("cluster.name");
    Set<Node> nodeSet = nodesClusterMap.get(clusterName);
    if (nodeSet != null) {
      nodeSet.remove(node);
      if (nodeSet.isEmpty()) {
        nodesClusterMap.remove(clusterName);
      }
    }
  }
}

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

public void bindNode(Node node) {
  String clusterName = node.settings().get("cluster.name");
  Set<Node> nodeSet = nodesClusterMap.get(clusterName);
  if (nodeSet == null) {
    nodeSet = new HashSet<Node>();
    nodesClusterMap.put(clusterName, nodeSet);
  }
  nodeSet.add(node);
}

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

public void unbindNode(Node node) {
    String clusterName = node.settings().get("cluster.name");
    Set<Node> nodeSet = nodesClusterMap.get(clusterName);
    if (nodeSet != null) {
      nodeSet.remove(node);
      if (nodeSet.isEmpty()) {
        nodesClusterMap.remove(clusterName);
      }
    }
  }
}

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

public void bindNode(Node node) {
  String clusterName = node.settings().get("cluster.name");
  Set<Node> nodeSet = nodesClusterMap.get(clusterName);
  if (nodeSet == null) {
    nodeSet = new HashSet<Node>();
    nodesClusterMap.put(clusterName, nodeSet);
  }
  nodeSet.add(node);
}

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

protected static String getUrl(final Node node, final String path) {
  final StringBuilder urlBuf = new StringBuilder(200);
  urlBuf.append("http://localhost:").append(node.settings().get("http.port"));
  if (path.startsWith("/")) {
    urlBuf.append(path);
  } else {
    urlBuf.append('/').append(path);
  }
  return urlBuf.toString();
}

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

@Override
  public String toString() {
    String nodeName = node.settings().get("name");
    String clusterName = node.settings().get("cluster.name");
    boolean local = Boolean.valueOf(node.settings().get("node.local"));
    String prefix;
    if (local) {
      prefix = "Local node";
    } else {
      prefix = "Node";
    }
    return String.format("%s [%s] - cluster [%s]", prefix, nodeName, clusterName);
  }
}

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

@Override public void close() throws Exception {
 node.close();
 // cleanup data dirs
 for (String name: Arrays.asList("path.data", "path.home")) {
  if (node.settings().get(name) != null) {
   File file = new File(node.settings().get(name));
   if (file.exists()) {
    file.delete();
   }
  }
 }
}

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

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

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

TribeClusterStateListener(Node tribeNode) {
  String tribeName = TRIBE_NAME_SETTING.get(tribeNode.settings());
  this.tribeName = tribeName;
  executor = new TribeNodeClusterStateTaskExecutor(tribeName);
}

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

TribeClusterStateListener(Node tribeNode) {
  String tribeName = TRIBE_NAME_SETTING.get(tribeNode.settings());
  this.tribeName = tribeName;
  executor = new TribeNodeClusterStateTaskExecutor(tribeName);
}

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

TribeClusterStateListener(Node tribeNode) {
  String tribeName = tribeNode.settings().get(TRIBE_NAME);
  this.tribeName = tribeName;
  executor = new TribeNodeClusterStateTaskExecutor(tribeName);
}

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

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

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

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

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

@Override public void close() throws Exception {
 node.close();
 // cleanup data dirs
 for (String name: Arrays.asList("path.data", "path.home")) {
  if (node.settings().get(name) != null) {
   File file = new File(node.settings().get(name));
   if (file.exists()) {
    file.delete();
   }
  }
 }
}

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

@Override
public void close() throws Exception {
  node.close();
  // cleanup data dirs
  for (String name : Arrays.asList("path.data", "path.home")) {
    if (node.settings().get(name) != null) {
      File file = new File(node.settings().get(name));
      if (file.exists()) {
        file.delete();
      }
    }
  }
}

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

Node

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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