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

Version.smallest介绍

[英]Returns the smallest version between the 2.
[中]返回2之间的最小版本。

代码示例

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

/**
 * Returns the minimum compatible version based on the current
 * version. Ie a node needs to have at least the return version in order
 * to communicate with a node running the current version. The returned version
 * is in most of the cases the smallest major version release unless the current version
 * is a beta or RC release then the version itself is returned.
 */
public Version minimumCompatibilityVersion() {
  return Version.smallest(this, fromId(major * 1000000 + 99));
}

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

public DiscoveryNodes build() {
  ImmutableOpenMap.Builder<String, DiscoveryNode> dataNodesBuilder = ImmutableOpenMap.builder();
  ImmutableOpenMap.Builder<String, DiscoveryNode> masterNodesBuilder = ImmutableOpenMap.builder();
  Version minNodeVersion = Version.CURRENT;
  Version minNonClientNodeVersion = Version.CURRENT;
  for (ObjectObjectCursor<String, DiscoveryNode> nodeEntry : nodes) {
    if (nodeEntry.value.dataNode()) {
      dataNodesBuilder.put(nodeEntry.key, nodeEntry.value);
      minNonClientNodeVersion = Version.smallest(minNonClientNodeVersion, nodeEntry.value.version());
    }
    if (nodeEntry.value.masterNode()) {
      masterNodesBuilder.put(nodeEntry.key, nodeEntry.value);
      minNonClientNodeVersion = Version.smallest(minNonClientNodeVersion, nodeEntry.value.version());
    }
    minNodeVersion = Version.smallest(minNodeVersion, nodeEntry.value.version());
  }
  return new DiscoveryNodes(nodes.build(), dataNodesBuilder.build(), masterNodesBuilder.build(), masterNodeId, localNodeId, minNodeVersion, minNonClientNodeVersion);
}

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

@Override
public void sendRequest(final DiscoveryNode node, final long requestId, final String action, final TransportRequest request, TransportRequestOptions options) throws IOException, TransportException {
  final Version version = Version.smallest(node.version(), this.version);
  try (BytesStreamOutput stream = new BytesStreamOutput()) {
    stream.setVersion(version);
    stream.writeLong(requestId);
    byte status = 0;
    status = TransportStatus.setRequest(status);
    stream.writeByte(status); // 0 for request, 1 for response.
    stream.writeString(action);
    request.writeTo(stream);
    stream.close();
    final LocalTransport targetTransport = connectedNodes.get(node);
    if (targetTransport == null) {
      throw new NodeNotConnectedException(node, "Node not connected");
    }
    final byte[] data = stream.bytes().toBytes();
    transportServiceAdapter.sent(data.length);
    transportServiceAdapter.onRequestSent(node, requestId, action, request, options);
    targetTransport.workers().execute(new Runnable() {
      @Override
      public void run() {
        targetTransport.messageReceived(data, action, LocalTransport.this, version, requestId);
      }
    });
  }
}

代码示例来源：origin: jprante/elasticsearch-transport-websocket

@Override
public void sendRequest(final DiscoveryNode node, final long requestId, final String action, final TransportRequest request, TransportRequestOptions options) throws IOException, TransportException {
  Channel targetChannel = nodeChannel(node, options);
  if (compress) {
    options.withCompress(true);
  }
  byte status = 0;
  status = TransportStatus.setRequest(status);
  BytesStreamOutput bStream = new BytesStreamOutput();
  bStream.skip(NettyHeader.HEADER_SIZE);
  StreamOutput stream = bStream;
  stream = new HandlesStreamOutput(stream);
  // we pick the smallest of the 2, to support both backward and forward compatibility
  // note, this is the only place we need to do this, since from here on, we use the serialized version
  // as the version to use also when the node receiving this request will send the response with
  Version version = Version.smallest(this.version, node.version());
  stream.setVersion(version);
  stream.writeString(action);
  ChannelBuffer buffer;
  request.writeTo(stream);
  stream.close();
  buffer = bStream.ourBytes().toChannelBuffer();
  NettyHeader.writeHeader(buffer, requestId, status, version);
  targetChannel.write(buffer);
}

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

final Version createdVersion = Version.smallest(version, nodes.smallestNonClientNodeVersion());
indexSettingsBuilder.put(SETTING_VERSION_CREATED, createdVersion);

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

minNonClientNodeVersion = Version.smallest(minNonClientNodeVersion, nodeEntry.value.getVersion());

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

Version version = Version.smallest(this.version, node.version());