本文整理了Java中org.elasticsearch.cluster.metadata.MetaData.addDefaultUnitsIfNeeded()
方法的一些代码示例,展示了MetaData.addDefaultUnitsIfNeeded()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。MetaData.addDefaultUnitsIfNeeded()
方法的具体详情如下:
包路径:org.elasticsearch.cluster.metadata.MetaData
类名称:MetaData
方法名:addDefaultUnitsIfNeeded
[英]As of 2.0 we require units for time and byte-sized settings. This methods adds default units to any settings that are part of timeSettings or byteSettings and don't specify a unit.
[中]从2.0开始,我们需要时间单位和字节大小的设置。此方法将默认单位添加到属于timeSettings或byteSettings的任何设置中,并且不指定单位。
代码示例来源:origin: com.strapdata.elasticsearch/elasticsearch
/**
* Decode global state from a string.
* @param stringMetaData
* @return
* @throws Exception
*/
public MetaData loadGlobalState(String stringMetaData) throws Exception {
MetaData globalState = MetaData.CASSANDRA_FORMAT.loadLatestState(logger, namedXContentRegistry, stringMetaData);
// ES 2.0 now requires units for all time and byte-sized settings, so we add the default unit if it's missing
// TODO: can we somehow only do this for pre-2.0 cluster state?
if (globalState != null) {
return MetaData.addDefaultUnitsIfNeeded(logger, globalState);
} else {
return null;
}
}
代码示例来源:origin: harbby/presto-connectors
/**
* Loads the global state, *without* index state, see {@link #loadFullState()} for that.
*/
MetaData loadGlobalState() throws IOException {
MetaData globalState = globalStateFormat.loadLatestState(logger, nodeEnv.nodeDataPaths());
// ES 2.0 now requires units for all time and byte-sized settings, so we add the default unit if it's missing
// TODO: can we somehow only do this for pre-2.0 cluster state?
if (globalState != null) {
return MetaData.addDefaultUnitsIfNeeded(logger, globalState);
} else {
return null;
}
}
代码示例来源:origin: com.strapdata.elasticsearch/elasticsearch
/**
* Loads the global state, *without* index state, see {@link #loadFullState()} for that.
*/
MetaData loadGlobalState() throws IOException {
MetaData globalState = MetaData.FORMAT.loadLatestState(logger, namedXContentRegistry, nodeEnv.nodeDataPaths());
// ES 2.0 now requires units for all time and byte-sized settings, so we add the default unit if it's missing
// TODO: can we somehow only do this for pre-2.0 cluster state?
if (globalState != null) {
return MetaData.addDefaultUnitsIfNeeded(logger, globalState);
} else {
return null;
}
}
代码示例来源:origin: harbby/presto-connectors
/**
* Elasticsearch 2.0 requires units on byte/memory and time settings; this method adds the default unit to any such settings that are
* missing units.
*/
private IndexMetaData addDefaultUnitsIfNeeded(IndexMetaData indexMetaData) {
if (indexMetaData.getCreationVersion().before(Version.V_2_0_0_beta1)) {
// TODO: can we somehow only do this *once* for a pre-2.0 index? Maybe we could stuff a "fake marker setting" here? Seems hackish...
// Created lazily if we find any settings that are missing units:
Settings settings = indexMetaData.getSettings();
Settings newSettings = MetaData.addDefaultUnitsIfNeeded(
INDEX_TIME_SETTINGS, INDEX_BYTES_SIZE_SETTINGS, logger, settings);
if (newSettings != null) {
// At least one setting was changed:
return IndexMetaData.builder(indexMetaData)
.version(indexMetaData.getVersion())
.settings(newSettings)
.build();
}
}
// No changes:
return indexMetaData;
}
代码示例来源:origin: com.strapdata.elasticsearch/elasticsearch
if (snapshotInfo.version().before(Version.V_2_0_0_beta1)) {
metaData = MetaData.addDefaultUnitsIfNeeded(logger, metaDataIn);
} else {
代码示例来源:origin: harbby/presto-connectors
IndexTemplateMetaData templateMetaData = cursor.value;
Settings currentSettings = templateMetaData.getSettings();
Settings newSettings = addDefaultUnitsIfNeeded(
MetaDataIndexUpgradeService.INDEX_TIME_SETTINGS,
MetaDataIndexUpgradeService.INDEX_BYTES_SIZE_SETTINGS,
代码示例来源:origin: harbby/presto-connectors
/** As of 2.0 we require units for time and byte-sized settings. This methods adds default units to any
* persistent settings and template settings that don't specify a unit.
**/
public static MetaData addDefaultUnitsIfNeeded(ESLogger logger, MetaData metaData) {
Settings newPersistentSettings = addDefaultUnitsIfNeeded(
CLUSTER_TIME_SETTINGS, CLUSTER_BYTES_SIZE_SETTINGS, logger, metaData.persistentSettings());
ImmutableOpenMap<String, IndexTemplateMetaData> templates = updateTemplates(logger, metaData.getTemplates());
if (newPersistentSettings != null || templates != null) {
return new MetaData(
metaData.clusterUUID(),
metaData.version(),
metaData.transientSettings(),
MoreObjects.firstNonNull(newPersistentSettings, metaData.persistentSettings()),
metaData.getIndices(),
MoreObjects.firstNonNull(templates, metaData.getTemplates()),
metaData.getCustoms(),
metaData.concreteAllIndices(),
metaData.concreteAllOpenIndices(),
metaData.concreteAllClosedIndices(),
metaData.getAliasAndIndexLookup());
} else {
// No changes:
return metaData;
}
}
代码示例来源:origin: harbby/presto-connectors
if (snapshot.version().before(Version.V_2_0_0_beta1)) {
metaData = MetaData.addDefaultUnitsIfNeeded(logger, metaDataIn);
} else {
内容来源于网络,如有侵权,请联系作者删除!