org.elasticsearch.common.settings.Settings.writeSettingsToStream()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(9.3k)|赞(0)|评价(0)|浏览(96)

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

Settings.writeSettingsToStream介绍

暂无

代码示例

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

@Override
public void writeTo(StreamOutput out) throws IOException {
  super.writeTo(out);
  writeSettingsToStream(transientSettings, out);
  writeSettingsToStream(persistentSettings, out);
}

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

@Override
public void writeTo(StreamOutput out) throws IOException {
  if (out.getVersion().onOrAfter(Version.V_6_4_0)) {
    super.writeTo(out);
    Settings.writeSettingsToStream(transientSettings, out);
    Settings.writeSettingsToStream(persistentSettings, out);
  } else {
    Settings.writeSettingsToStream(transientSettings, out);
    Settings.writeSettingsToStream(persistentSettings, out);
    out.writeBoolean(acknowledged);
  }
}

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

/**
 * Writes repository metadata to stream output
 *
 * @param out stream output
 */
public void writeTo(StreamOutput out) throws IOException {
  out.writeString(name);
  out.writeString(type);
  Settings.writeSettingsToStream(settings, out);
}

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

@Override
public void writeTo(StreamOutput out) throws IOException {
  out.writeOptionalString(name);
  boolean isNotNullDefinition = this.definition != null;
  out.writeBoolean(isNotNullDefinition);
  if (isNotNullDefinition) {
    Settings.writeSettingsToStream(definition, out);
  }
}

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

@Override
public void writeTo(StreamOutput out) throws IOException {
  out.writeString(clusterUUID);
  out.writeLong(version);
  Settings.writeSettingsToStream(transientSettings, out);
  Settings.writeSettingsToStream(persistentSettings, out);
  indices.writeTo(out);
  templates.writeTo(out);
  customs.writeTo(out);
}

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

@Override
public void writeTo(StreamOutput out) throws IOException {
  super.writeTo(out);
  out.writeStringArrayNullable(indices);
  indicesOptions.writeIndicesOptions(out);
  writeSettingsToStream(settings, out);
  out.writeBoolean(preserveExisting);
}

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

@Override
public void writeTo(StreamOutput out) throws IOException {
  super.writeTo(out);
  out.writeString(name);
  out.writeString(type);
  writeSettingsToStream(settings, out);
  out.writeBoolean(verify);
}

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

@Override
public void writeTo(StreamOutput out) throws IOException {
  super.writeTo(out);
  out.writeVInt(indexToSettings.size());
  for (ObjectObjectCursor<String, Settings> cursor : indexToSettings) {
    out.writeString(cursor.key);
    Settings.writeSettingsToStream(cursor.value, out);
  }
  if (out.getVersion().onOrAfter(Version.V_6_4_0)) {
    out.writeVInt(indexToDefaultSettings.size());
    for (ObjectObjectCursor<String, Settings> cursor : indexToDefaultSettings) {
      out.writeString(cursor.key);
      Settings.writeSettingsToStream(cursor.value, out);
    }
  }
}

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

@Override
public void writeTo(StreamOutput out) throws IOException {
  super.writeTo(out);
  out.writeString(cause);
  out.writeString(index);
  writeSettingsToStream(settings, out);
  out.writeVInt(mappings.size());
  for (Map.Entry<String, String> entry : mappings.entrySet()) {
    out.writeString(entry.getKey());
    out.writeString(entry.getValue());
  }
  if (out.getVersion().before(Version.V_6_5_0)) {
    // Size of custom index metadata, which is removed
    out.writeVInt(0);
  }
  out.writeVInt(aliases.size());
  for (Alias alias : aliases) {
    alias.writeTo(out);
  }
  out.writeBoolean(updateAllTypes);
  waitForActiveShards.writeTo(out);
}

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

@Override
public void writeTo(StreamOutput out) throws IOException {
  super.writeTo(out);
  out.writeString(cause);
  out.writeString(name);
  if (out.getVersion().onOrAfter(Version.V_6_0_0_alpha1)) {
    out.writeStringList(indexPatterns);
  } else {
    out.writeString(indexPatterns.size() > 0 ? indexPatterns.get(0) : "");
  }
  out.writeInt(order);
  out.writeBoolean(create);
  writeSettingsToStream(settings, out);
  out.writeVInt(mappings.size());
  for (Map.Entry<String, String> entry : mappings.entrySet()) {
    out.writeString(entry.getKey());
    out.writeString(entry.getValue());
  }
  if (out.getVersion().before(Version.V_6_5_0)) {
    out.writeVInt(0);
  }
  out.writeVInt(aliases.size());
  for (Alias alias : aliases) {
    alias.writeTo(out);
  }
  out.writeOptionalVInt(version);
}

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

@Override
public void writeTo(StreamOutput out) throws IOException {
  super.writeTo(out);
  out.writeString(snapshot);
  out.writeString(repository);
  out.writeStringArray(indices);
  indicesOptions.writeIndicesOptions(out);
  out.writeOptionalString(renamePattern);
  out.writeOptionalString(renameReplacement);
  out.writeBoolean(waitForCompletion);
  out.writeBoolean(includeGlobalState);
  out.writeBoolean(partial);
  out.writeBoolean(includeAliases);
  writeSettingsToStream(settings, out);
  writeSettingsToStream(indexSettings, out);
  out.writeStringArray(ignoreIndexSettings);
}

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

@Override
public void writeTo(StreamOutput out) throws IOException {
  super.writeTo(out);
  out.writeString(snapshot);
  out.writeString(repository);
  out.writeStringArray(indices);
  indicesOptions.writeIndicesOptions(out);
  writeSettingsToStream(settings, out);
  out.writeBoolean(includeGlobalState);
  out.writeBoolean(waitForCompletion);
  out.writeBoolean(partial);
}

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

@Override
public void writeTo(StreamOutput out) throws IOException {
  out.writeLong(version);
  out.writeString(clusterUUID);
  writeSettingsToStream(transientSettings, out);
  writeSettingsToStream(persistentSettings, out);
  out.writeVInt(indices.size());
  for (IndexMetaData indexMetaData : this) {
    indexMetaData.writeTo(out);
  }
  out.writeVInt(templates.size());
  for (ObjectCursor<IndexTemplateMetaData> cursor : templates.values()) {
    cursor.value.writeTo(out);
  }
  // filter out custom states not supported by the other node
  int numberOfCustoms = 0;
  for (final ObjectCursor<Custom> cursor : customs.values()) {
    if (FeatureAware.shouldSerialize(out, cursor.value)) {
      numberOfCustoms++;
    }
  }
  out.writeVInt(numberOfCustoms);
  for (final ObjectCursor<Custom> cursor : customs.values()) {
    if (FeatureAware.shouldSerialize(out, cursor.value)) {
      out.writeNamedWriteable(cursor.value);
    }
  }
}

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

for (ObjectObjectCursor<String, Settings> indexEntry : settings) {
  out.writeString(indexEntry.key);
  Settings.writeSettingsToStream(indexEntry.value, out);
  for (ObjectObjectCursor<String, Settings> indexEntry : defaultSettings) {
    out.writeString(indexEntry.key);
    Settings.writeSettingsToStream(indexEntry.value, out);

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

@Override
public void writeTo(StreamOutput out) throws IOException {
  out.writeString(name);
  out.writeInt(order);
  if (out.getVersion().onOrAfter(Version.V_6_0_0_alpha1)) {
    out.writeStringList(patterns);
  } else {
    out.writeString(patterns.get(0));
  }
  Settings.writeSettingsToStream(settings, out);
  out.writeVInt(mappings.size());
  for (ObjectObjectCursor<String, CompressedXContent> cursor : mappings) {
    out.writeString(cursor.key);
    cursor.value.writeTo(out);
  }
  out.writeVInt(aliases.size());
  for (ObjectCursor<AliasMetaData> cursor : aliases.values()) {
    cursor.value.writeTo(out);
  }
  if (out.getVersion().before(Version.V_6_5_0)) {
    out.writeVInt(0);
  }
  if (out.getVersion().onOrAfter(Version.V_5_0_0_beta1)) {
    out.writeOptionalVInt(version);
  }
}

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

@Override
  public void writeTo(StreamOutput out) throws IOException {
    super.writeTo(out);
    Settings.writeSettingsToStream(transientSettings, out);
    Settings.writeSettingsToStream(persistentSettings, out);
    writeAcknowledged(out);
  }
}

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

@Override
public void writeTo(StreamOutput out) throws IOException {
  out.writeString(index);
  out.writeInt(routingNumShards);
  out.writeLong(version);
  if (out.getVersion().onOrAfter(Version.V_6_5_0)) {
    out.writeVLong(mappingVersion);
  }
  if (out.getVersion().onOrAfter(Version.V_6_5_0)) {
    out.writeVLong(settingsVersion);
  }
  out.writeByte(state.id);
  Settings.writeSettingsToStream(settings, out);
  out.writeVLongArray(primaryTerms);
  mappings.writeTo(out);
  aliases.writeTo(out);
  customData.writeTo(out);
  inSyncAllocationIds.writeTo(out);
  if (out.getVersion().onOrAfter(Version.V_6_4_0)) {
    rolloverInfos.writeTo(out);
  }
}

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

@Override
  public void writeTo(StreamOutput out) throws IOException {
    super.writeTo(out);
    out.writeVInt(version.id);
    Build.writeBuild(build, out);
    if (totalIndexingBuffer == null) {
      out.writeBoolean(false);
    } else {
      out.writeBoolean(true);
      out.writeLong(totalIndexingBuffer.getBytes());
    }
    if (settings == null) {
      out.writeBoolean(false);
    } else {
      out.writeBoolean(true);
      Settings.writeSettingsToStream(settings, out);
    }
    out.writeOptionalWriteable(os);
    out.writeOptionalWriteable(process);
    out.writeOptionalWriteable(jvm);
    out.writeOptionalWriteable(threadPool);
    out.writeOptionalWriteable(transport);
    out.writeOptionalWriteable(http);
    out.writeOptionalWriteable(plugins);
    out.writeOptionalWriteable(ingest);
  }
}

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

@Override
  public void writeTo(StreamOutput out) throws IOException {
    super.writeTo(out);
    out.writeVInt(indexToSettings.size());
    for (ObjectObjectCursor<String, Settings> cursor : indexToSettings) {
      out.writeString(cursor.key);
      Settings.writeSettingsToStream(cursor.value, out);
    }
  }
}

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

writeSettingsToStream(settings, out);
out.writeVLongArray(primaryTerms);
out.writeVInt(mappings.size());

内容来源于网络，如有侵权，请联系作者删除！

settings

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Settings类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com