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

DiscoveryNodes.delta介绍

[英]Returns the changes comparing this nodes to the provided nodes.
[中]返回将此节点与提供的节点进行比较的更改。

代码示例

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

public ClusterChangedEvent(String source, ClusterState state, ClusterState previousState) {
  Objects.requireNonNull(source, "source must not be null");
  Objects.requireNonNull(state, "state must not be null");
  Objects.requireNonNull(previousState, "previousState must not be null");
  this.source = source;
  this.state = state;
  this.previousState = previousState;
  this.nodesDelta = state.nodes().delta(previousState.nodes());
}

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

public ClusterChangedEvent(String source, ClusterState state, ClusterState previousState) {
  Objects.requireNonNull(source, "source must not be null");
  Objects.requireNonNull(state, "state must not be null");
  Objects.requireNonNull(previousState, "previousState must not be null");
  this.source = source;
  this.state = state;
  this.previousState = previousState;
  this.nodesDelta = state.nodes().delta(previousState.nodes());
}

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

public ClusterChangedEvent(String source, ClusterState state, ClusterState previousState, boolean peristMetaData) {
  Objects.requireNonNull(source, "source must not be null");
  Objects.requireNonNull(state, "state must not be null");
  Objects.requireNonNull(previousState, "previousState must not be null");
  this.source = source;
  this.state = state;
  this.previousState = previousState;
  this.nodesDelta = state.nodes().delta(previousState.nodes());
  this.peristMetaData = peristMetaData;
}

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

public ClusterChangedEvent(String source, ClusterState state, ClusterState previousState) {
  Objects.requireNonNull(source, "source must not be null");
  Objects.requireNonNull(state, "state must not be null");
  Objects.requireNonNull(previousState, "previousState must not be null");
  this.source = source;
  this.state = state;
  this.previousState = previousState;
  this.nodesDelta = state.nodes().delta(previousState.nodes());
}

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

public ClusterChangedEvent(String source, ClusterState state, ClusterState previousState) {
  Objects.requireNonNull(source, "source must not be null");
  Objects.requireNonNull(state, "state must not be null");
  Objects.requireNonNull(previousState, "previousState must not be null");
  this.source = source;
  this.state = state;
  this.previousState = previousState;
  this.nodesDelta = state.nodes().delta(previousState.nodes());
}

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

@Override
public ClusterTasksResult<LocalClusterUpdateTask> execute(ClusterState currentState) {
  DiscoveryNodes newNodes = currentState.nodes().removeDeadMembers(newMembers, master.localNode().getId());
  DiscoveryNodes.Delta delta = newNodes.delta(currentState.nodes());
  if (delta.added()) {
    logger.warn("No new nodes should be created when a new discovery view is accepted");
  }
  // reroute here, so we eagerly remove dead nodes from the routing
  ClusterState updatedState = ClusterState.builder(currentState).nodes(newNodes).build();
  return newState(master.allocationService.deassociateDeadNodes(updatedState, true, "node stopped"));
}

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

@Override
public ClusterState execute(ClusterState currentState) {
  DiscoveryNodes newNodes = currentState.nodes().removeDeadMembers(newMembers, master.localNode().id());
  DiscoveryNodes.Delta delta = newNodes.delta(currentState.nodes());
  if (delta.added()) {
    logger.warn("No new nodes should be created when a new discovery view is accepted");
  }
  // reroute here, so we eagerly remove dead nodes from the routing
  ClusterState updatedState = ClusterState.builder(currentState).nodes(newNodes).build();
  RoutingAllocation.Result routingResult = master.routingService.getAllocationService().reroute(
      ClusterState.builder(updatedState).build(), "elected as master");
  return ClusterState.builder(updatedState).routingResult(routingResult).build();
}