Class MetaData
- java.lang.Object
-
- org.elasticsearch.cluster.metadata.MetaData
-
- All Implemented Interfaces:
java.lang.Iterable<IndexMetaData>,Diffable<MetaData>,Writeable,ToXContent,ToXContentFragment
public class MetaData extends java.lang.Object implements java.lang.Iterable<IndexMetaData>, Diffable<MetaData>, ToXContentFragment
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classMetaData.Builderstatic interfaceMetaData.Customstatic classMetaData.XContentContext-
Nested classes/interfaces inherited from interface org.elasticsearch.common.xcontent.ToXContent
ToXContent.DelegatingMapParams, ToXContent.MapParams, ToXContent.Params
-
Nested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable
Writeable.Reader<V>, Writeable.Writer<V>
-
-
Field Summary
Fields Modifier and Type Field Description static java.lang.StringALLstatic java.util.EnumSet<MetaData.XContentContext>ALL_CONTEXTSIndicates that this custom metadata will be returned as part of an API call, stored as a part of a snapshot global state, and will be persisted between node restartsstatic java.util.EnumSet<MetaData.XContentContext>API_AND_GATEWAYIndicates that this custom metadata will be returned as part of an API call and will be persisted between node restarts, but will not be a part of a snapshot global statestatic java.util.EnumSet<MetaData.XContentContext>API_AND_SNAPSHOTIndicates that this custom metadata will be returned as part of an API call and stored as a part of a snapshot global state, but will not be persisted between node restartsstatic java.util.EnumSet<MetaData.XContentContext>API_ONLYIndicates that this custom metadata will be returned as part of an API call but will not be persistedstatic ClusterBlockCLUSTER_READ_ONLY_ALLOW_DELETE_BLOCKstatic ClusterBlockCLUSTER_READ_ONLY_BLOCKstatic java.lang.StringCONTEXT_MODE_GATEWAYstatic java.lang.StringCONTEXT_MODE_PARAMstatic java.lang.StringCONTEXT_MODE_SNAPSHOTstatic MetaDataEMPTY_META_DATAstatic MetaDataStateFormat<MetaData>FORMATState format forMetaDatato write to and load from diskstatic java.lang.StringGLOBAL_STATE_FILE_PREFIXstatic Setting<java.lang.Integer>SETTING_CLUSTER_MAX_SHARDS_PER_NODEstatic Setting<java.lang.Boolean>SETTING_READ_ONLY_ALLOW_DELETE_SETTINGstatic Setting<java.lang.Boolean>SETTING_READ_ONLY_SETTINGstatic java.lang.StringUNKNOWN_CLUSTER_UUID-
Fields inherited from interface org.elasticsearch.common.xcontent.ToXContent
EMPTY_PARAMS
-
-
Method Summary
Modifier and Type Method Description static MetaData.Builderbuilder()static MetaData.Builderbuilder(MetaData metaData)java.lang.StringclusterUUID()booleanclusterUUIDCommitted()Whether the current node with the given cluster state is locked into the cluster with the UUID returned byclusterUUID(), meaning that it will not accept any cluster state with a different clusterUUID.CoordinationMetaDatacoordinationMetaData()<T extends MetaData.Custom>
Tcustom(java.lang.String type)ImmutableOpenMap<java.lang.String,MetaData.Custom>customs()Diff<MetaData>diff(MetaData previousState)Returns serializable object representing differences between this and previousStatebooleanequalsAliases(MetaData other)ImmutableOpenMap<java.lang.String,java.util.List<AliasMetaData>>findAliases(AliasesRequest aliasesRequest, java.lang.String[] concreteIndices)Finds the specific index aliases that match with the specified aliases directly or partially via wildcards, and that point to the specified concrete indices (directly or matching indices via wildcards).ImmutableOpenMap<java.lang.String,java.util.List<AliasMetaData>>findAllAliases(java.lang.String[] concreteIndices)Finds the specific index aliases that point to the requested concrete indices directly or that match with the indices via wildcards.ImmutableOpenMap<java.lang.String,ImmutableOpenMap<java.lang.String,MappingMetaData>>findMappings(java.lang.String[] concreteIndices, java.lang.String[] types, java.util.function.Function<java.lang.String,java.util.function.Predicate<java.lang.String>> fieldFilter)Finds all mappings for types and concrete indices.static MetaDatafromXContent(XContentParser parser)java.util.SortedMap<java.lang.String,AliasOrIndex>getAliasAndIndexLookup()java.lang.String[]getConcreteAllClosedIndices()java.lang.String[]getConcreteAllIndices()Returns all the concrete indices.java.lang.String[]getConcreteAllOpenIndices()ImmutableOpenMap<java.lang.String,MetaData.Custom>getCustoms()IndexMetaDatagetIndexSafe(Index index)Returns theIndexMetaDatafor this index.ImmutableOpenMap<java.lang.String,IndexMetaData>getIndices()ImmutableOpenMap<java.lang.String,IndexTemplateMetaData>getTemplates()intgetTotalNumberOfShards()Gets the total number of shards from all indices, including replicas and closed indices.intgetTotalOpenIndexShards()Gets the total number of open shards from all indices.booleanhasAlias(java.lang.String alias)booleanhasAliases(java.lang.String[] aliases, java.lang.String[] concreteIndices)Checks if at least one of the specified aliases exists in the specified concrete indices.booleanhasConcreteIndex(java.lang.String index)booleanhasIndex(java.lang.String index)booleanhasIndexMetaData(IndexMetaData indexMetaData)Returns true iff existing index has the sameIndexMetaDatainstanceIndexMetaDataindex(java.lang.String index)IndexMetaDataindex(Index index)IndexGraveyardindexGraveyard()The collection of index deletions in the cluster.ImmutableOpenMap<java.lang.String,IndexMetaData>indices()static booleanisAllTypes(java.lang.String[] types)Identifies whether the array containing type names given as argument refers to all types The empty or null array identifies all typesstatic booleanisExplicitAllType(java.lang.String[] types)Identifies whether the array containing type names given as argument explicitly refers to all types The empty or null array doesn't explicitly map to all typesstatic booleanisGlobalStateEquals(MetaData metaData1, MetaData metaData2)java.util.Iterator<IndexMetaData>iterator()SettingspersistentSettings()static Diff<MetaData>readDiffFrom(StreamInput in)static MetaDatareadFrom(StreamInput in)java.lang.StringresolveIndexRouting(java.lang.String routing, java.lang.String aliasOrIndex)Returns indexing routing for the given index.java.lang.StringresolveWriteIndexRouting(java.lang.String routing, java.lang.String aliasOrIndex)Returns indexing routing for the givenaliasOrIndex.booleanroutingRequired(java.lang.String concreteIndex)Settingssettings()Returns the merged transient and persistent settings.ImmutableOpenMap<java.lang.String,IndexTemplateMetaData>templates()XContentBuildertoXContent(XContentBuilder builder, ToXContent.Params params)SettingstransientSettings()longversion()voidwriteTo(StreamOutput out)Write this into the StreamOutput.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.elasticsearch.common.xcontent.ToXContentFragment
isFragment
-
-
-
-
Field Detail
-
ALL
public static final java.lang.String ALL
- See Also:
- Constant Field Values
-
UNKNOWN_CLUSTER_UUID
public static final java.lang.String UNKNOWN_CLUSTER_UUID
- See Also:
- Constant Field Values
-
API_ONLY
public static java.util.EnumSet<MetaData.XContentContext> API_ONLY
Indicates that this custom metadata will be returned as part of an API call but will not be persisted
-
API_AND_GATEWAY
public static java.util.EnumSet<MetaData.XContentContext> API_AND_GATEWAY
Indicates that this custom metadata will be returned as part of an API call and will be persisted between node restarts, but will not be a part of a snapshot global state
-
API_AND_SNAPSHOT
public static java.util.EnumSet<MetaData.XContentContext> API_AND_SNAPSHOT
Indicates that this custom metadata will be returned as part of an API call and stored as a part of a snapshot global state, but will not be persisted between node restarts
-
ALL_CONTEXTS
public static java.util.EnumSet<MetaData.XContentContext> ALL_CONTEXTS
Indicates that this custom metadata will be returned as part of an API call, stored as a part of a snapshot global state, and will be persisted between node restarts
-
SETTING_CLUSTER_MAX_SHARDS_PER_NODE
public static final Setting<java.lang.Integer> SETTING_CLUSTER_MAX_SHARDS_PER_NODE
-
SETTING_READ_ONLY_SETTING
public static final Setting<java.lang.Boolean> SETTING_READ_ONLY_SETTING
-
CLUSTER_READ_ONLY_BLOCK
public static final ClusterBlock CLUSTER_READ_ONLY_BLOCK
-
SETTING_READ_ONLY_ALLOW_DELETE_SETTING
public static final Setting<java.lang.Boolean> SETTING_READ_ONLY_ALLOW_DELETE_SETTING
-
CLUSTER_READ_ONLY_ALLOW_DELETE_BLOCK
public static final ClusterBlock CLUSTER_READ_ONLY_ALLOW_DELETE_BLOCK
-
EMPTY_META_DATA
public static final MetaData EMPTY_META_DATA
-
CONTEXT_MODE_PARAM
public static final java.lang.String CONTEXT_MODE_PARAM
- See Also:
- Constant Field Values
-
CONTEXT_MODE_SNAPSHOT
public static final java.lang.String CONTEXT_MODE_SNAPSHOT
-
CONTEXT_MODE_GATEWAY
public static final java.lang.String CONTEXT_MODE_GATEWAY
-
GLOBAL_STATE_FILE_PREFIX
public static final java.lang.String GLOBAL_STATE_FILE_PREFIX
- See Also:
- Constant Field Values
-
FORMAT
public static final MetaDataStateFormat<MetaData> FORMAT
State format forMetaDatato write to and load from disk
-
-
Method Detail
-
version
public long version()
-
clusterUUID
public java.lang.String clusterUUID()
-
clusterUUIDCommitted
public boolean clusterUUIDCommitted()
Whether the current node with the given cluster state is locked into the cluster with the UUID returned byclusterUUID(), meaning that it will not accept any cluster state with a different clusterUUID.
-
settings
public Settings settings()
Returns the merged transient and persistent settings.
-
transientSettings
public Settings transientSettings()
-
persistentSettings
public Settings persistentSettings()
-
coordinationMetaData
public CoordinationMetaData coordinationMetaData()
-
hasAlias
public boolean hasAlias(java.lang.String alias)
-
equalsAliases
public boolean equalsAliases(MetaData other)
-
getAliasAndIndexLookup
public java.util.SortedMap<java.lang.String,AliasOrIndex> getAliasAndIndexLookup()
-
findAllAliases
public ImmutableOpenMap<java.lang.String,java.util.List<AliasMetaData>> findAllAliases(java.lang.String[] concreteIndices)
Finds the specific index aliases that point to the requested concrete indices directly or that match with the indices via wildcards.- Parameters:
concreteIndices- The concrete indices that the aliases must point to in order to be returned.- Returns:
- A map of index name to the list of aliases metadata. If a concrete index does not have matching aliases then the result will not include the index's key.
-
findAliases
public ImmutableOpenMap<java.lang.String,java.util.List<AliasMetaData>> findAliases(AliasesRequest aliasesRequest, java.lang.String[] concreteIndices)
Finds the specific index aliases that match with the specified aliases directly or partially via wildcards, and that point to the specified concrete indices (directly or matching indices via wildcards).- Parameters:
aliasesRequest- The request to find aliases forconcreteIndices- The concrete indices that the aliases must point to in order to be returned.- Returns:
- A map of index name to the list of aliases metadata. If a concrete index does not have matching aliases then the result will not include the index's key.
-
hasAliases
public boolean hasAliases(java.lang.String[] aliases, java.lang.String[] concreteIndices)Checks if at least one of the specified aliases exists in the specified concrete indices. Wildcards are supported in the alias names for partial matches.- Parameters:
aliases- The names of the index aliases to findconcreteIndices- The concrete indexes the index aliases must point to order to be returned.- Returns:
- whether at least one of the specified aliases exists in one of the specified concrete indices.
-
findMappings
public ImmutableOpenMap<java.lang.String,ImmutableOpenMap<java.lang.String,MappingMetaData>> findMappings(java.lang.String[] concreteIndices, java.lang.String[] types, java.util.function.Function<java.lang.String,java.util.function.Predicate<java.lang.String>> fieldFilter) throws java.io.IOException
Finds all mappings for types and concrete indices. Types are expanded to include all types that match the glob patterns in the types array. Empty types array, null or {"_all"} will be expanded to all types available for the given indices. Only fields that match the provided field filter will be returned (default is a predicate that always returns true, which can be overridden via plugins)- Throws:
java.io.IOException- See Also:
MapperPlugin.getFieldFilter()
-
getConcreteAllIndices
public java.lang.String[] getConcreteAllIndices()
Returns all the concrete indices.
-
getConcreteAllOpenIndices
public java.lang.String[] getConcreteAllOpenIndices()
-
getConcreteAllClosedIndices
public java.lang.String[] getConcreteAllClosedIndices()
-
resolveWriteIndexRouting
public java.lang.String resolveWriteIndexRouting(@Nullable java.lang.String routing, java.lang.String aliasOrIndex)
Returns indexing routing for the givenaliasOrIndex. Resolves routing from the alias metadata used in the write index.
-
resolveIndexRouting
public java.lang.String resolveIndexRouting(@Nullable java.lang.String routing, java.lang.String aliasOrIndex)
Returns indexing routing for the given index.
-
hasIndex
public boolean hasIndex(java.lang.String index)
-
hasConcreteIndex
public boolean hasConcreteIndex(java.lang.String index)
-
index
public IndexMetaData index(java.lang.String index)
-
index
public IndexMetaData index(Index index)
-
hasIndexMetaData
public boolean hasIndexMetaData(IndexMetaData indexMetaData)
Returns true iff existing index has the sameIndexMetaDatainstance
-
getIndexSafe
public IndexMetaData getIndexSafe(Index index)
Returns theIndexMetaDatafor this index.- Throws:
IndexNotFoundException- if no metadata for this index is found
-
indices
public ImmutableOpenMap<java.lang.String,IndexMetaData> indices()
-
getIndices
public ImmutableOpenMap<java.lang.String,IndexMetaData> getIndices()
-
templates
public ImmutableOpenMap<java.lang.String,IndexTemplateMetaData> templates()
-
getTemplates
public ImmutableOpenMap<java.lang.String,IndexTemplateMetaData> getTemplates()
-
customs
public ImmutableOpenMap<java.lang.String,MetaData.Custom> customs()
-
getCustoms
public ImmutableOpenMap<java.lang.String,MetaData.Custom> getCustoms()
-
indexGraveyard
public IndexGraveyard indexGraveyard()
The collection of index deletions in the cluster.
-
custom
public <T extends MetaData.Custom> T custom(java.lang.String type)
-
getTotalNumberOfShards
public int getTotalNumberOfShards()
Gets the total number of shards from all indices, including replicas and closed indices.- Returns:
- The total number shards from all indices.
-
getTotalOpenIndexShards
public int getTotalOpenIndexShards()
Gets the total number of open shards from all indices. Includes replicas, but does not include shards that are part of closed indices.- Returns:
- The total number of open shards from all indices.
-
isAllTypes
public static boolean isAllTypes(java.lang.String[] types)
Identifies whether the array containing type names given as argument refers to all types The empty or null array identifies all types- Parameters:
types- the array containing types- Returns:
- true if the provided array maps to all types, false otherwise
-
isExplicitAllType
public static boolean isExplicitAllType(java.lang.String[] types)
Identifies whether the array containing type names given as argument explicitly refers to all types The empty or null array doesn't explicitly map to all types- Parameters:
types- the array containing index names- Returns:
- true if the provided array explicitly maps to all types, false otherwise
-
routingRequired
public boolean routingRequired(java.lang.String concreteIndex)
- Parameters:
concreteIndex- The concrete index to check if routing is required- Returns:
- Whether routing is required according to the mapping for the specified index and type
-
iterator
public java.util.Iterator<IndexMetaData> iterator()
- Specified by:
iteratorin interfacejava.lang.Iterable<IndexMetaData>
-
isGlobalStateEquals
public static boolean isGlobalStateEquals(MetaData metaData1, MetaData metaData2)
-
diff
public Diff<MetaData> diff(MetaData previousState)
Description copied from interface:DiffableReturns serializable object representing differences between this and previousState
-
readDiffFrom
public static Diff<MetaData> readDiffFrom(StreamInput in) throws java.io.IOException
- Throws:
java.io.IOException
-
fromXContent
public static MetaData fromXContent(XContentParser parser) throws java.io.IOException
- Throws:
java.io.IOException
-
toXContent
public XContentBuilder toXContent(XContentBuilder builder, ToXContent.Params params) throws java.io.IOException
- Specified by:
toXContentin interfaceToXContent- Throws:
java.io.IOException
-
readFrom
public static MetaData readFrom(StreamInput in) throws java.io.IOException
- Throws:
java.io.IOException
-
writeTo
public void writeTo(StreamOutput out) throws java.io.IOException
Description copied from interface:WriteableWrite this into the StreamOutput.
-
builder
public static MetaData.Builder builder()
-
builder
public static MetaData.Builder builder(MetaData metaData)
-
-