org.elasticsearch.cluster.node.DiscoveryNodes.getMasterNodes()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(10.1k)|赞(0)|评价(0)|浏览(89)

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

DiscoveryNodes.getMasterNodes介绍

[英]Get a Map of the discovered master nodes arranged by their ids
[中]获取按ID排列的已发现主节点的映射

代码示例

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

public void logMinimumMasterNodesWarningIfNecessary(ClusterState oldState, ClusterState newState) {
  // check if min_master_nodes setting is too low and log warning
  if (hasTooManyMasterNodes(oldState.nodes()) == false && hasTooManyMasterNodes(newState.nodes())) {
    logger.warn("value for setting \"{}\" is too low. This can result in data loss! Please set it to at least a quorum of master-" +
        "eligible nodes (current value: [{}], total number of master-eligible nodes used for publishing in this round: [{}])",
      ElectMasterService.DISCOVERY_ZEN_MINIMUM_MASTER_NODES_SETTING.getKey(), minimumMasterNodes(),
      newState.getNodes().getMasterNodes().size());
  }
}

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

final DiscoveryNodes nodes = contextProvider.clusterState().nodes();
for (ObjectCursor<DiscoveryNode> masterNode : nodes.getMasterNodes().values()) {
  seedAddresses.add(masterNode.value.getAddress());

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

logger.debug("not recovering from gateway, nodes_size (data) [{}] < recover_after_data_nodes [{}]",
    nodes.getDataNodes().size(), recoverAfterDataNodes);
} else if (recoverAfterMasterNodes != -1 && nodes.getMasterNodes().size() < recoverAfterMasterNodes) {
  logger.debug("not recovering from gateway, nodes_size (master) [{}] < recover_after_master_nodes [{}]",
    nodes.getMasterNodes().size(), recoverAfterMasterNodes);
} else {
  boolean enforceRecoverAfterTime;
      enforceRecoverAfterTime = true;
      reason = "expecting [" + expectedDataNodes + "] data nodes, but only have [" + nodes.getDataNodes().size() + "]";
    } else if (expectedMasterNodes != -1 && (nodes.getMasterNodes().size() < expectedMasterNodes)) {
      reason = "expecting [" + expectedMasterNodes + "] master nodes, but only have [" + nodes.getMasterNodes().size() + "]";

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

nodesToPublishTo = new HashSet<>(nodes.getSize());
DiscoveryNode localNode = nodes.getLocalNode();
final int totalMasterNodes = nodes.getMasterNodes().size();
for (final DiscoveryNode node : nodes) {
  if (node.equals(localNode) == false) {

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

public void performStateRecovery(final GatewayStateRecoveredListener listener) throws GatewayException {
  String[] nodesIds = clusterService.state().nodes().getMasterNodes().keys().toArray(String.class);
  logger.trace("performing state recovery from {}", Arrays.toString(nodesIds));
  TransportNodesListGatewayMetaState.NodesGatewayMetaState nodesState = listGatewayMetaState.list(nodesIds, null).actionGet();

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

this::handleMinimumMasterNodesChanged, (value) -> {
  final ClusterState clusterState = this.clusterState();
  int masterNodes = clusterState.nodes().getMasterNodes().size();

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

public void logMinimumMasterNodesWarningIfNecessary(ClusterState oldState, ClusterState newState) {
  // check if min_master_nodes setting is too low and log warning
  if (hasTooManyMasterNodes(oldState.nodes()) == false && hasTooManyMasterNodes(newState.nodes())) {
    logger.warn("value for setting \"{}\" is too low. This can result in data loss! Please set it to at least a quorum of master-" +
        "eligible nodes (current value: [{}], total number of master-eligible nodes used for publishing in this round: [{}])",
      ElectMasterService.DISCOVERY_ZEN_MINIMUM_MASTER_NODES_SETTING.getKey(), minimumMasterNodes(),
      newState.getNodes().getMasterNodes().size());
  }
}

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

public void logMinimumMasterNodesWarningIfNecessary(ClusterState oldState, ClusterState newState) {
  // check if min_master_nodes setting is too low and log warning
  if (hasTooManyMasterNodes(oldState.nodes()) == false && hasTooManyMasterNodes(newState.nodes())) {
    logger.warn("value for setting \"{}\" is too low. This can result in data loss! Please set it to at least a quorum of master-" +
        "eligible nodes (current value: [{}], total number of master-eligible nodes used for publishing in this round: [{}])",
      ElectMasterService.DISCOVERY_ZEN_MINIMUM_MASTER_NODES_SETTING.getKey(), minimumMasterNodes(),
      newState.getNodes().getMasterNodes().size());
  }
}

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

public void logMinimumMasterNodesWarningIfNecessary(ClusterState oldState, ClusterState newState) {
  // check if min_master_nodes setting is too low and log warning
  if (hasTooManyMasterNodes(oldState.nodes()) == false && hasTooManyMasterNodes(newState.nodes())) {
    logger.warn("value for setting \"{}\" is too low. This can result in data loss! Please set it to at least a quorum of master-" +
        "eligible nodes (current value: [{}], total number of master-eligible nodes used for publishing in this round: [{}])",
      ElectMasterService.DISCOVERY_ZEN_MINIMUM_MASTER_NODES_SETTING.getKey(), minimumMasterNodes(),
      newState.getNodes().getMasterNodes().size());
  }
}

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

final DiscoveryNodes nodes = contextProvider.clusterState().nodes();
for (ObjectCursor<DiscoveryNode> masterNode : nodes.getMasterNodes().values()) {
  seedAddresses.add(masterNode.value.getAddress());

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

final DiscoveryNodes nodes = contextProvider.clusterState().nodes();
for (ObjectCursor<DiscoveryNode> masterNode : nodes.getMasterNodes().values()) {
  seedAddresses.add(masterNode.value.getAddress());

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

final DiscoveryNodes nodes = contextProvider.clusterState().nodes();
for (ObjectCursor<DiscoveryNode> masterNode : nodes.getMasterNodes().values()) {
  seedNodes.add(masterNode.value);

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

logger.debug("not recovering from gateway, nodes_size (data) [{}] < recover_after_data_nodes [{}]",
    nodes.getDataNodes().size(), recoverAfterDataNodes);
} else if (recoverAfterMasterNodes != -1 && nodes.getMasterNodes().size() < recoverAfterMasterNodes) {
  logger.debug("not recovering from gateway, nodes_size (master) [{}] < recover_after_master_nodes [{}]",
    nodes.getMasterNodes().size(), recoverAfterMasterNodes);
} else {
  boolean enforceRecoverAfterTime;
      enforceRecoverAfterTime = true;
      reason = "expecting [" + expectedDataNodes + "] data nodes, but only have [" + nodes.getDataNodes().size() + "]";
    } else if (expectedMasterNodes != -1 && (nodes.getMasterNodes().size() < expectedMasterNodes)) { // does not meet the expected...
      enforceRecoverAfterTime = true;
      reason = "expecting [" + expectedMasterNodes + "] master nodes, but only have [" + nodes.getMasterNodes().size() + "]";

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

logger.debug("not recovering from gateway, nodes_size (data) [{}] < recover_after_data_nodes [{}]",
    nodes.getDataNodes().size(), recoverAfterDataNodes);
} else if (recoverAfterMasterNodes != -1 && nodes.getMasterNodes().size() < recoverAfterMasterNodes) {
  logger.debug("not recovering from gateway, nodes_size (master) [{}] < recover_after_master_nodes [{}]",
    nodes.getMasterNodes().size(), recoverAfterMasterNodes);
} else {
  boolean enforceRecoverAfterTime;
      enforceRecoverAfterTime = true;
      reason = "expecting [" + expectedDataNodes + "] data nodes, but only have [" + nodes.getDataNodes().size() + "]";
    } else if (expectedMasterNodes != -1 && (nodes.getMasterNodes().size() < expectedMasterNodes)) { // does not meet the expected...
      enforceRecoverAfterTime = true;
      reason = "expecting [" + expectedMasterNodes + "] master nodes, but only have [" + nodes.getMasterNodes().size() + "]";

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

logger.debug("not recovering from gateway, nodes_size (data) [{}] < recover_after_data_nodes [{}]",
    nodes.getDataNodes().size(), recoverAfterDataNodes);
} else if (recoverAfterMasterNodes != -1 && nodes.getMasterNodes().size() < recoverAfterMasterNodes) {
  logger.debug("not recovering from gateway, nodes_size (master) [{}] < recover_after_master_nodes [{}]",
    nodes.getMasterNodes().size(), recoverAfterMasterNodes);
} else {
  boolean enforceRecoverAfterTime;
      enforceRecoverAfterTime = true;
      reason = "expecting [" + expectedDataNodes + "] data nodes, but only have [" + nodes.getDataNodes().size() + "]";
    } else if (expectedMasterNodes != -1 && (nodes.getMasterNodes().size() < expectedMasterNodes)) { // does not meet the expected...
      enforceRecoverAfterTime = true;
      reason = "expecting [" + expectedMasterNodes + "] master nodes, but only have [" + nodes.getMasterNodes().size() + "]";

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

nodesToPublishTo = new HashSet<>(nodes.getSize());
DiscoveryNode localNode = nodes.getLocalNode();
final int totalMasterNodes = nodes.getMasterNodes().size();
for (final DiscoveryNode node : nodes) {
  if (node.equals(localNode) == false) {

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

nodesToPublishTo = new HashSet<>(nodes.getSize());
DiscoveryNode localNode = nodes.getLocalNode();
final int totalMasterNodes = nodes.getMasterNodes().size();
for (final DiscoveryNode node : nodes) {
  if (node.equals(localNode) == false) {

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

nodesToPublishTo = new HashSet<>(nodes.getSize());
DiscoveryNode localNode = nodes.getLocalNode();
final int totalMasterNodes = nodes.getMasterNodes().size();
for (final DiscoveryNode node : nodes) {
  if (node.equals(localNode) == false) {

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

this::handleMinimumMasterNodesChanged, (value) -> {
  final ClusterState clusterState = this.clusterState();
  int masterNodes = clusterState.nodes().getMasterNodes().size();

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

this::handleMinimumMasterNodesChanged, (value) -> {
  final ClusterState clusterState = clusterService.state();
  int masterNodes = clusterState.nodes().getMasterNodes().size();

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

DiscoveryNodes

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    DiscoveryNodes类方法

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