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

TransportService.getLocalNode介绍

暂无

代码示例

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

@Override
public void onSuccess(String source) {
  latch.countDown();
  ackListener.onNodeAck(transportService.getLocalNode(), null);
}

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

@Override
  public void onFailure(String source, Exception e) {
    latch.countDown();
    ackListener.onNodeAck(transportService.getLocalNode(), e);
    logger.warn(() -> new ParameterizedMessage("failed while applying cluster state locally [{}]", event.source()), e);
  }
};

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

@Override
protected synchronized void doStart() {
  // set initial state
  DiscoveryNode localNode = transportService.getLocalNode();
  clusterState = createInitialState(localNode);
  clusterApplier.setInitialState(clusterState);
}

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

try {
  logger.trace("joining master {}", masterNode);
  membership.sendJoinRequestBlocking(masterNode, transportService.getLocalNode(), joinTimeout);
  return true;
} catch (Exception e) {

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

/**
 * Used by {@link TransportSearchAction} to send the expand queries (field collapsing).
 */
void sendExecuteMultiSearch(final MultiSearchRequest request, SearchTask task,
              final ActionListener<MultiSearchResponse> listener) {
  final Transport.Connection connection = transportService.getConnection(transportService.getLocalNode());
  transportService.sendChildRequest(connection, MultiSearchAction.NAME, request, task,
      new ConnectionCountingHandler<>(listener, MultiSearchResponse::new, clientConnections, connection.getNode().getId()));
}

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

final DiscoveryNode localNode = transportService.getLocalNode();

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

/** Updates the shard snapshot status by sending a {@link UpdateIndexShardSnapshotStatusRequest} to the master node */
void sendSnapshotShardUpdate(final Snapshot snapshot,
               final ShardId shardId,
               final ShardSnapshotStatus status,
               final DiscoveryNode masterNode) {
  try {
    if (masterNode.getVersion().onOrAfter(Version.V_6_1_0)) {
      UpdateIndexShardSnapshotStatusRequest request = new UpdateIndexShardSnapshotStatusRequest(snapshot, shardId, status);
      transportService.sendRequest(transportService.getLocalNode(), UPDATE_SNAPSHOT_STATUS_ACTION_NAME, request, INSTANCE_SAME);
    } else {
      UpdateSnapshotStatusRequestV6 requestV6 = new UpdateSnapshotStatusRequestV6(snapshot, shardId, status);
      transportService.sendRequest(masterNode, UPDATE_SNAPSHOT_STATUS_ACTION_NAME_V6, requestV6, INSTANCE_SAME);
    }
  } catch (Exception e) {
    logger.warn(() -> new ParameterizedMessage("[{}] [{}] failed to update snapshot state", snapshot, status), e);
  }
}

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

incomingState = ClusterState.readFrom(in, transportService.getLocalNode());
fullClusterStateReceivedCount.incrementAndGet();
logger.debug("received full cluster state version [{}] with size [{}]", incomingState.version(),

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

if (transportService.getLocalNode().equals(masterNode)) {
  final int requiredJoins = Math.max(0, electMaster.minimumMasterNodes() - 1); // we count as one
  logger.debug("elected as master, waiting for incoming joins ([{}] needed)", requiredJoins);

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

@Override
protected void doStart() {
  DiscoveryNode localNode = transportService.getLocalNode();
  assert localNode != null;
  synchronized (stateMutex) {
    // set initial state
    assert committedState.get() == null;
    assert localNode != null;
    ClusterState.Builder builder = clusterApplier.newClusterStateBuilder();
    ClusterState initialState = builder
      .blocks(ClusterBlocks.builder()
        .addGlobalBlock(STATE_NOT_RECOVERED_BLOCK)
        .addGlobalBlock(discoverySettings.getNoMasterBlock()))
      .nodes(DiscoveryNodes.builder().add(localNode).localNodeId(localNode.getId()))
      .build();
    committedState.set(initialState);
    clusterApplier.setInitialState(initialState);
    nodesFD.setLocalNode(localNode);
    joinThreadControl.start();
  }
  zenPing.start();
}

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

public NodeInfo info(boolean settings, boolean os, boolean process, boolean jvm, boolean threadPool,
      boolean transport, boolean http, boolean plugin, boolean ingest, boolean indices) {
  return new NodeInfo(Version.CURRENT, Build.CURRENT, transportService.getLocalNode(),
      settings ? settingsFilter.filter(this.settings) : null,
      os ? monitorService.osService().info() : null,
      process ? monitorService.processService().info() : null,
      jvm ? monitorService.jvmService().info() : null,
      threadPool ? this.threadPool.info() : null,
      transport ? transportService.info() : null,
      http ? (httpServerTransport == null ? null : httpServerTransport.info()) : null,
      plugin ? (pluginService == null ? null : pluginService.info()) : null,
      ingest ? (ingestService == null ? null : ingestService.info()) : null,
      indices ? indicesService.getTotalIndexingBufferBytes() : null
  );
}

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

public NodeStats stats(CommonStatsFlags indices, boolean os, boolean process, boolean jvm, boolean threadPool,
            boolean fs, boolean transport, boolean http, boolean circuitBreaker,
            boolean script, boolean discoveryStats, boolean ingest, boolean adaptiveSelection) {
  // for indices stats we want to include previous allocated shards stats as well (it will
  // only be applied to the sensible ones to use, like refresh/merge/flush/indexing stats)
  return new NodeStats(transportService.getLocalNode(), System.currentTimeMillis(),
      indices.anySet() ? indicesService.stats(true, indices) : null,
      os ? monitorService.osService().stats() : null,
      process ? monitorService.processService().stats() : null,
      jvm ? monitorService.jvmService().stats() : null,
      threadPool ? this.threadPool.stats() : null,
      fs ? monitorService.fsService().stats() : null,
      transport ? transportService.stats() : null,
      http ? (httpServerTransport == null ? null : httpServerTransport.stats()) : null,
      circuitBreaker ? circuitBreakerService.stats() : null,
      script ? scriptService.stats() : null,
      discoveryStats ? discovery.stats() : null,
      ingest ? ingestService.stats() : null,
      adaptiveSelection ? responseCollectorService.getAdaptiveStats(searchTransportService.getPendingSearchRequests()) : null
  );
}

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

@Override
public void onSuccess(String source) {
  latch.countDown();
  ackListener.onNodeAck(transportService.getLocalNode(), null);
}

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

transportService.start();
assert localNodeFactory.getNode() != null;
assert transportService.getLocalNode().equals(localNodeFactory.getNode())
  : "transportService has a different local node than the factory provided";
final MetaData onDiskMetadata;

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

@Override
  public void onFailure(String source, Exception e) {
    latch.countDown();
    ackListener.onNodeAck(transportService.getLocalNode(), e);
    logger.warn(() -> new ParameterizedMessage("failed while applying cluster state locally [{}]", event.source()), e);
  }
};

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

@Override
protected synchronized void doStart() {
  // set initial state
  DiscoveryNode localNode = transportService.getLocalNode();
  clusterState = createInitialState(localNode);
  clusterApplier.setInitialState(clusterState);
}

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

@Override
protected synchronized void doStart() {
  // set initial state
  DiscoveryNode localNode = transportService.getLocalNode();
  clusterState = createInitialState(localNode);
  clusterApplier.setInitialState(clusterState);
}

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

/**
 * Used by {@link TransportSearchAction} to send the expand queries (field collapsing).
 */
void sendExecuteMultiSearch(final MultiSearchRequest request, SearchTask task,
                  final ActionListener<MultiSearchResponse> listener) {
  transportService.sendChildRequest(transportService.getConnection(transportService.getLocalNode()), MultiSearchAction.NAME, request,
    task, new ActionListenerResponseHandler<>(listener, MultiSearchResponse::new));
}

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

/**
 * Used by {@link TransportSearchAction} to send the expand queries (field collapsing).
 */
void sendExecuteMultiSearch(final MultiSearchRequest request, SearchTask task,
              final ActionListener<MultiSearchResponse> listener) {
  final Transport.Connection connection = transportService.getConnection(transportService.getLocalNode());
  transportService.sendChildRequest(connection, MultiSearchAction.NAME, request, task,
      new ConnectionCountingHandler<>(listener, MultiSearchResponse::new, clientConnections, connection.getNode().getId()));
}

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

/**
 * Used by {@link TransportSearchAction} to send the expand queries (field collapsing).
 */
void sendExecuteMultiSearch(final MultiSearchRequest request, SearchTask task,
              final ActionListener<MultiSearchResponse> listener) {
  final Transport.Connection connection = transportService.getConnection(transportService.getLocalNode());
  transportService.sendChildRequest(connection, MultiSearchAction.NAME, request, task,
      new ConnectionCountingHandler<>(listener, MultiSearchResponse::new, clientConnections, connection.getNode().getId()));
}