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

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

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

Version.readVersion介绍

暂无

代码示例

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

private HandshakeResponse(StreamInput in) throws IOException {
  super.readFrom(in);
  responseVersion = Version.readVersion(in);
}

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

public HandshakeResponse(StreamInput in) throws IOException {
  super(in);
  discoveryNode = in.readOptionalWriteable(DiscoveryNode::new);
  clusterName = new ClusterName(in);
  version = Version.readVersion(in);
}

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

HandshakeRequest(StreamInput streamInput) throws IOException {
  super(streamInput);
  BytesReference remainingMessage;
  try {
    remainingMessage = streamInput.readBytesReference();
  } catch (EOFException e) {
    remainingMessage = null;
  }
  if (remainingMessage == null) {
    version = null;
  } else {
    try (StreamInput messageStreamInput = remainingMessage.streamInput()) {
      this.version = Version.readVersion(messageStreamInput);
    }
  }
}

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

@Override
public void readFrom(StreamInput in) throws IOException {
  shardId = ShardId.readShardId(in);
  primary = in.readBoolean();
  upgradeVersion = Version.readVersion(in);
  try {
    oldestLuceneSegment = org.apache.lucene.util.Version.parse(in.readString());
  } catch (ParseException ex) {
    throw new IOException("failed to parse lucene version [" + oldestLuceneSegment + "]", ex);
  }
}

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

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  int size = in.readVInt();
  versions = new HashMap<>();
  for (int i=0; i<size; i++) {
    String index = in.readString();
    Version upgradeVersion = Version.readVersion(in);
    String oldestLuceneSegment = in.readString();
    versions.put(index, new Tuple<>(upgradeVersion, oldestLuceneSegment));
  }
}

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

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  int size = in.readVInt();
  versions = new HashMap<>();
  for (int i=0; i<size; i++) {
    String index = in.readString();
    Version upgradeVersion = Version.readVersion(in);
    String oldestLuceneSegment = in.readString();
    versions.put(index, new Tuple<>(upgradeVersion, oldestLuceneSegment));
  }
}

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

SnapshotRecoverySource(StreamInput in) throws IOException {
  if (in.getVersion().onOrAfter(Version.V_6_6_0)) {
    restoreUUID = in.readString();
  } else {
    restoreUUID = RestoreInProgress.BWC_UUID;
  }
  snapshot = new Snapshot(in);
  version = Version.readVersion(in);
  index = in.readString();
}

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

this.roles.add(in.readEnum(Role.class));
this.version = Version.readVersion(in);

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

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  nodeName = in.readString();
  version = Version.readVersion(in);
  clusterName = new ClusterName(in);
  clusterUuid = in.readString();
  build = Build.readBuild(in);
  available = in.readBoolean();
}

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

version = Version.readVersion(in);
} else {
  version = in.readBoolean() ? Version.readVersion(in) : null;

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

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  version = Version.readVersion(in);
  build = Build.readBuild(in);
  if (in.readBoolean()) {
    totalIndexingBuffer = new ByteSizeValue(in.readLong());
  } else {
    totalIndexingBuffer = null;
  }
  if (in.readBoolean()) {
    settings = Settings.readSettingsFromStream(in);
  }
  os = in.readOptionalWriteable(OsInfo::new);
  process = in.readOptionalWriteable(ProcessInfo::new);
  jvm = in.readOptionalWriteable(JvmInfo::new);
  threadPool = in.readOptionalWriteable(ThreadPoolInfo::new);
  transport = in.readOptionalWriteable(TransportInfo::new);
  http = in.readOptionalWriteable(HttpInfo::new);
  plugins = in.readOptionalWriteable(PluginsAndModules::new);
  ingest = in.readOptionalWriteable(IngestInfo::new);
}

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

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  version = Version.readVersion(in);
}

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

this.version = in.readString();
if (in.getVersion().onOrAfter(Version.V_6_3_0)) {
  elasticsearchVersion = Version.readVersion(in);
  javaVersion = in.readString();
} else {

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

SnapshotRecoverySource(StreamInput in) throws IOException {
  snapshot = new Snapshot(in);
  version = Version.readVersion(in);
  index = in.readString();
}

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

SnapshotRecoverySource(StreamInput in) throws IOException {
  snapshot = new Snapshot(in);
  version = Version.readVersion(in);
  index = in.readString();
}

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

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  int size = in.readVInt();
  versions = new HashMap<>();
  for (int i=0; i<size; i++) {
    String index = in.readString();
    Version upgradeVersion = Version.readVersion(in);
    String oldestLuceneSegment = in.readString();
    versions.put(index, new Tuple<>(upgradeVersion, oldestLuceneSegment));
  }
}

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

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  int size = in.readVInt();
  versions = new HashMap<>();
  for (int i=0; i<size; i++) {
    String index = in.readString();
    Version upgradeVersion = Version.readVersion(in);
    String oldestLuceneSegment = in.readString();
    versions.put(index, new Tuple<>(upgradeVersion, oldestLuceneSegment));
  }
}

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

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  discoveryNode = in.readOptionalWriteable(DiscoveryNode::new);
  clusterName = new ClusterName(in);
  version = Version.readVersion(in);
}

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

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  discoveryNode = in.readOptionalWriteable(DiscoveryNode::new);
  clusterName = new ClusterName(in);
  version = Version.readVersion(in);
}

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

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  int size = in.readVInt();
  versions = new HashMap<>();
  for (int i=0; i<size; i++) {
    String index = in.readString();
    Version upgradeVersion = Version.readVersion(in);
    String oldestLuceneSegment = in.readString();
    versions.put(index, new Tuple<>(upgradeVersion, oldestLuceneSegment));
  }
}

相关文章