Class DataStream
java.lang.Object
org.elasticsearch.cluster.AbstractDiffable<DataStream>
org.elasticsearch.cluster.metadata.DataStream
- All Implemented Interfaces:
Diffable<DataStream>
,Writeable
,org.elasticsearch.common.xcontent.ToXContent
,org.elasticsearch.common.xcontent.ToXContentObject
public final class DataStream extends AbstractDiffable<DataStream> implements org.elasticsearch.common.xcontent.ToXContentObject
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
DataStream.TimestampField
Nested classes/interfaces inherited from interface org.elasticsearch.common.xcontent.ToXContent
org.elasticsearch.common.xcontent.ToXContent.DelegatingMapParams, org.elasticsearch.common.xcontent.ToXContent.MapParams, org.elasticsearch.common.xcontent.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.String
BACKING_INDEX_PREFIX
static DateFormatter
DATE_FORMATTER
static org.elasticsearch.common.ParseField
GENERATION_FIELD
static org.elasticsearch.common.ParseField
HIDDEN_FIELD
static org.elasticsearch.common.ParseField
INDICES_FIELD
static org.elasticsearch.common.ParseField
METADATA_FIELD
static org.elasticsearch.common.ParseField
NAME_FIELD
static Version
NEW_FEATURES_VERSION
The version when data stream metadata, hidden and replicated data streams, and dates in backing index names was introduced.static org.elasticsearch.common.ParseField
REPLICATED_FIELD
static org.elasticsearch.common.ParseField
TIMESTAMP_FIELD_FIELD
-
Constructor Summary
Constructors Constructor Description DataStream(java.lang.String name, DataStream.TimestampField timeStampField, java.util.List<Index> indices)
DataStream(java.lang.String name, DataStream.TimestampField timeStampField, java.util.List<Index> indices, long generation, java.util.Map<java.lang.String,java.lang.Object> metadata)
DataStream(java.lang.String name, DataStream.TimestampField timeStampField, java.util.List<Index> indices, long generation, java.util.Map<java.lang.String,java.lang.Object> metadata, boolean hidden, boolean replicated)
DataStream(StreamInput in)
-
Method Summary
Modifier and Type Method Description boolean
equals(java.lang.Object o)
static DataStream
fromXContent(org.elasticsearch.common.xcontent.XContentParser parser)
static java.lang.String
getDefaultBackingIndexName(java.lang.String dataStreamName, long generation)
Generates the name of the index that conforms to the default naming convention for backing indices on data streams given the specified data stream name and generation and the current system time.static java.lang.String
getDefaultBackingIndexName(java.lang.String dataStreamName, long generation, long epochMillis)
Generates the name of the index that conforms to the default naming convention for backing indices on data streams given the specified data stream name, generation, and time.static java.lang.String
getDefaultBackingIndexName(java.lang.String dataStreamName, long generation, long epochMillis, Version minNodeVersion)
static java.lang.String
getDefaultBackingIndexName(java.lang.String dataStreamName, long generation, Version minNodeVersion)
long
getGeneration()
java.util.List<Index>
getIndices()
static java.lang.String
getLegacyDefaultBackingIndexName(java.lang.String dataStreamName, long generation)
java.util.Map<java.lang.String,java.lang.Object>
getMetadata()
java.lang.String
getName()
DataStream.TimestampField
getTimeStampField()
Index
getWriteIndex()
int
hashCode()
boolean
isHidden()
boolean
isReplicated()
Determines whether this data stream is replicated from elsewhere, for example a remote cluster.DataStream
promoteDataStream()
static Diff<DataStream>
readDiffFrom(StreamInput in)
DataStream
removeBackingIndex(Index index)
Removes the specified backing index and returns a newDataStream
instance with the remaining backing indices.DataStream
replaceBackingIndex(Index existingBackingIndex, Index newBackingIndex)
Replaces the specified backing index with a new index and returns a newDataStream
instance with the modified backing indices.DataStream
rollover(Index newWriteIndex, Version minNodeVersion)
Performs a rollover on aDataStream
instance and returns a new instance containing the updated list of backing indices and incremented generation.org.elasticsearch.common.xcontent.XContentBuilder
toXContent(org.elasticsearch.common.xcontent.XContentBuilder builder, org.elasticsearch.common.xcontent.ToXContent.Params params)
void
writeTo(StreamOutput out)
Write this into the StreamOutput.
-
Field Details
-
BACKING_INDEX_PREFIX
public static final java.lang.String BACKING_INDEX_PREFIX- See Also:
- Constant Field Values
-
DATE_FORMATTER
-
NEW_FEATURES_VERSION
The version when data stream metadata, hidden and replicated data streams, and dates in backing index names was introduced. -
NAME_FIELD
public static final org.elasticsearch.common.ParseField NAME_FIELD -
TIMESTAMP_FIELD_FIELD
public static final org.elasticsearch.common.ParseField TIMESTAMP_FIELD_FIELD -
INDICES_FIELD
public static final org.elasticsearch.common.ParseField INDICES_FIELD -
GENERATION_FIELD
public static final org.elasticsearch.common.ParseField GENERATION_FIELD -
METADATA_FIELD
public static final org.elasticsearch.common.ParseField METADATA_FIELD -
HIDDEN_FIELD
public static final org.elasticsearch.common.ParseField HIDDEN_FIELD -
REPLICATED_FIELD
public static final org.elasticsearch.common.ParseField REPLICATED_FIELD
-
-
Constructor Details
-
DataStream
public DataStream(java.lang.String name, DataStream.TimestampField timeStampField, java.util.List<Index> indices, long generation, java.util.Map<java.lang.String,java.lang.Object> metadata) -
DataStream
public DataStream(java.lang.String name, DataStream.TimestampField timeStampField, java.util.List<Index> indices, long generation, java.util.Map<java.lang.String,java.lang.Object> metadata, boolean hidden, boolean replicated) -
DataStream
public DataStream(java.lang.String name, DataStream.TimestampField timeStampField, java.util.List<Index> indices) -
DataStream
- Throws:
java.io.IOException
-
-
Method Details
-
getName
public java.lang.String getName() -
getTimeStampField
-
getIndices
-
getGeneration
public long getGeneration() -
getWriteIndex
-
getMetadata
@Nullable public java.util.Map<java.lang.String,java.lang.Object> getMetadata() -
isHidden
public boolean isHidden() -
isReplicated
public boolean isReplicated()Determines whether this data stream is replicated from elsewhere, for example a remote cluster.- Returns:
- Whether this data stream is replicated.
-
rollover
Performs a rollover on aDataStream
instance and returns a new instance containing the updated list of backing indices and incremented generation.- Parameters:
newWriteIndex
- the new write backing index. Must conform to the naming convention for backing indices on data streams. SeegetDefaultBackingIndexName(java.lang.String, long)
.- Returns:
- new
DataStream
instance with the rollover operation applied
-
removeBackingIndex
Removes the specified backing index and returns a newDataStream
instance with the remaining backing indices.- Parameters:
index
- the backing index to remove- Returns:
- new
DataStream
instance with the remaining backing indices
-
replaceBackingIndex
Replaces the specified backing index with a new index and returns a newDataStream
instance with the modified backing indices. AnIllegalArgumentException
is thrown if the index to be replaced is not a backing index for this data stream or if it is theDataStream
's write index.- Parameters:
existingBackingIndex
- the backing index to be replacednewBackingIndex
- the new index that will be part of theDataStream
- Returns:
- new
DataStream
instance with backing indices that contain replacement index instead of the specified existing index.
-
promoteDataStream
-
getDefaultBackingIndexName
public static java.lang.String getDefaultBackingIndexName(java.lang.String dataStreamName, long generation)Generates the name of the index that conforms to the default naming convention for backing indices on data streams given the specified data stream name and generation and the current system time.- Parameters:
dataStreamName
- name of the data streamgeneration
- generation of the data stream- Returns:
- backing index name
-
getDefaultBackingIndexName
public static java.lang.String getDefaultBackingIndexName(java.lang.String dataStreamName, long generation, Version minNodeVersion) -
getDefaultBackingIndexName
public static java.lang.String getDefaultBackingIndexName(java.lang.String dataStreamName, long generation, long epochMillis)Generates the name of the index that conforms to the default naming convention for backing indices on data streams given the specified data stream name, generation, and time.- Parameters:
dataStreamName
- name of the data streamgeneration
- generation of the data streamepochMillis
- creation time for the backing index- Returns:
- backing index name
-
getDefaultBackingIndexName
public static java.lang.String getDefaultBackingIndexName(java.lang.String dataStreamName, long generation, long epochMillis, Version minNodeVersion) -
getLegacyDefaultBackingIndexName
public static java.lang.String getLegacyDefaultBackingIndexName(java.lang.String dataStreamName, long generation) -
readDiffFrom
- Throws:
java.io.IOException
-
writeTo
Description copied from interface:Writeable
Write this into the StreamOutput. -
fromXContent
public static DataStream fromXContent(org.elasticsearch.common.xcontent.XContentParser parser) throws java.io.IOException- Throws:
java.io.IOException
-
toXContent
public org.elasticsearch.common.xcontent.XContentBuilder toXContent(org.elasticsearch.common.xcontent.XContentBuilder builder, org.elasticsearch.common.xcontent.ToXContent.Params params) throws java.io.IOException- Specified by:
toXContent
in interfaceorg.elasticsearch.common.xcontent.ToXContent
- Throws:
java.io.IOException
-
equals
public boolean equals(java.lang.Object o)- Overrides:
equals
in classjava.lang.Object
-
hashCode
public int hashCode()- Overrides:
hashCode
in classjava.lang.Object
-