org.elasticsearch.Version.writeVersion()方法的使用及代码示例

x33g5p2x  于2022-02-01 转载在 其他  
字(6.9k)|赞(0)|评价(0)|浏览(100)

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

Version.writeVersion介绍

暂无

代码示例

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

@Override
public void writeTo(StreamOutput out) throws IOException {
  super.writeTo(out);
  assert responseVersion != null;
  Version.writeVersion(responseVersion, out);
}

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

@Override
  public void writeTo(StreamOutput out) throws IOException {
    super.writeTo(out);
    out.writeVInt(versions.size());
    for(Map.Entry<String, Tuple<Version, String>> entry : versions.entrySet()) {
      out.writeString(entry.getKey());
      Version.writeVersion(entry.getValue().v1(), out);
      out.writeString(entry.getValue().v2());
    }
  }
}

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

@Override
public void writeTo(StreamOutput out) throws IOException {
  super.writeTo(out);
  out.writeVInt(versions.size());
  for(Map.Entry<String, Tuple<Version, String>> entry : versions.entrySet()) {
    out.writeString(entry.getKey());
    Version.writeVersion(entry.getValue().v1(), out);
    out.writeString(entry.getValue().v2());
  }
}

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

@Override
public void writeTo(StreamOutput out) throws IOException {
  super.writeTo(out);
  out.writeOptionalWriteable(discoveryNode);
  clusterName.writeTo(out);
  Version.writeVersion(version, out);
}

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

@Override
  public void writeTo(StreamOutput streamOutput) throws IOException {
    super.writeTo(streamOutput);
    assert version != null;
    try (BytesStreamOutput messageStreamOutput = new BytesStreamOutput(4)) {
      Version.writeVersion(version, messageStreamOutput);
      BytesReference reference = messageStreamOutput.bytes();
      streamOutput.writeBytesReference(reference);
    }
  }
}

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

@Override
  public void writeTo(StreamOutput out) throws IOException {
    shardId.writeTo(out);
    out.writeBoolean(primary);
    Version.writeVersion(upgradeVersion, out);
    out.writeString(oldestLuceneSegment.toString());
  }
}

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

@Override
public void writeTo(StreamOutput out) throws IOException {
  out.writeString(nodeName);
  out.writeString(nodeId);
  out.writeString(ephemeralId);
  out.writeString(hostName);
  out.writeString(hostAddress);
  address.writeTo(out);
  out.writeVInt(attributes.size());
  for (Map.Entry<String, String> entry : attributes.entrySet()) {
    out.writeString(entry.getKey());
    out.writeString(entry.getValue());
  }
  out.writeVInt(roles.size());
  for (Role role : roles) {
    out.writeEnum(role);
  }
  Version.writeVersion(version, out);
}

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

@Override
protected void writeAdditionalFields(StreamOutput out) throws IOException {
  if (out.getVersion().onOrAfter(Version.V_6_6_0)) {
    out.writeString(restoreUUID);
  }
  snapshot.writeTo(out);
  Version.writeVersion(version, out);
  out.writeString(index);
}

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

@Override
public void writeTo(StreamOutput out) throws IOException {
  super.writeTo(out);
  out.writeString(nodeName);
  Version.writeVersion(version, out);
  clusterName.writeTo(out);
  out.writeString(clusterUuid);
  Build.writeBuild(build, out);
  out.writeBoolean(available);
}

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

versionToWrite = Version.CURRENT;
  Version.writeVersion(versionToWrite, out);
} else {
  if (version != null) {
    out.writeBoolean(true);
    Version.writeVersion(version, out);
  } else {
    out.writeBoolean(false);

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

@Override
  public void writeTo(StreamOutput out) throws IOException {
    super.writeTo(out);
    assert version != null;
    Version.writeVersion(version, out);
  }
}

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

@Override
public void writeTo(final StreamOutput out) throws IOException {
  out.writeString(name);
  out.writeString(description);
  out.writeString(version);
  if (out.getVersion().onOrAfter(Version.V_6_3_0)) {
    Version.writeVersion(elasticsearchVersion, out);
    out.writeString(javaVersion);
  }
  out.writeString(classname);
  if (out.getVersion().onOrAfter(Version.V_6_2_0)) {
    out.writeStringList(extendedPlugins);
  }
  if (out.getVersion().onOrAfter(Version.V_5_4_0)) {
    out.writeBoolean(hasNativeController);
  }
  if (out.getVersion().onOrAfter(Version.V_6_0_0_beta2) && out.getVersion().before(Version.V_6_3_0)) {
    /*
     * Elasticsearch versions in [6.0.0-beta2, 6.3.0) allowed plugins to specify that they require the keystore and this was
     * serialized into the plugin info. Therefore, we have to write out a value for this boolean.
     */
    out.writeBoolean(false);
  }
}

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

@Override
protected void writeAdditionalFields(StreamOutput out) throws IOException {
  snapshot.writeTo(out);
  Version.writeVersion(version, out);
  out.writeString(index);
}

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

@Override
  public void writeTo(StreamOutput out) throws IOException {
    super.writeTo(out);
    out.writeVInt(versions.size());
    for(Map.Entry<String, Tuple<Version, String>> entry : versions.entrySet()) {
      out.writeString(entry.getKey());
      Version.writeVersion(entry.getValue().v1(), out);
      out.writeString(entry.getValue().v2());
    }
  }
}

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

@Override
public void writeTo(StreamOutput out) throws IOException {
  super.writeTo(out);
  out.writeVInt(versions.size());
  for(Map.Entry<String, Tuple<Version, String>> entry : versions.entrySet()) {
    out.writeString(entry.getKey());
    Version.writeVersion(entry.getValue().v1(), out);
    out.writeString(entry.getValue().v2());
  }
}

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

@Override
  public void writeTo(StreamOutput out) throws IOException {
    super.writeTo(out);
    out.writeVInt(versions.size());
    for(Map.Entry<String, Tuple<Version, String>> entry : versions.entrySet()) {
      out.writeString(entry.getKey());
      Version.writeVersion(entry.getValue().v1(), out);
      out.writeString(entry.getValue().v2());
    }
    writeTimeout(out);
  }
}

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

@Override
public void writeTo(StreamOutput out) throws IOException {
  super.writeTo(out);
  out.writeOptionalWriteable(discoveryNode);
  clusterName.writeTo(out);
  Version.writeVersion(version, out);
}

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

@Override
  public void writeTo(StreamOutput out) throws IOException {
    shardId.writeTo(out);
    out.writeBoolean(primary);
    Version.writeVersion(upgradeVersion, out);
    out.writeString(oldestLuceneSegment.toString());
  }
}

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

@Override
  public void writeTo(StreamOutput out) throws IOException {
    shardId.writeTo(out);
    out.writeBoolean(primary);
    Version.writeVersion(upgradeVersion, out);
    out.writeString(oldestLuceneSegment.toString());
  }
}

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

@Override
public void writeTo(StreamOutput out) throws IOException {
  super.writeTo(out);
  out.writeString(nodeName);
  Version.writeVersion(version, out);
  clusterName.writeTo(out);
  out.writeString(clusterUuid);
  Build.writeBuild(build, out);
  out.writeBoolean(available);
}

相关文章