Class DataStreamTestHelper

java.lang.Object
org.opensearch.cluster.DataStreamTestHelper
public final class DataStreamTestHelper extends Object

  • Constructor Details

    • DataStreamTestHelper

      public DataStreamTestHelper()

  • Method Details

    • createFirstBackingIndex

      public static org.opensearch.cluster.metadata.IndexMetadata.Builder createFirstBackingIndex(String dataStreamName)

    • createBackingIndex

      public static org.opensearch.cluster.metadata.IndexMetadata.Builder createBackingIndex(String dataStreamName, int generation)

    • getIndexMetadataBuilderForIndex

      public static org.opensearch.cluster.metadata.IndexMetadata.Builder getIndexMetadataBuilderForIndex(org.opensearch.core.index.Index index)

    • createTimestampField

      public static org.opensearch.cluster.metadata.DataStream.TimestampField createTimestampField(String fieldName)

    • generateMapping

      public static String generateMapping(String timestampFieldName)

    • generateMapping

      public static String generateMapping(String timestampFieldName, String type)

    • randomIndexInstances

      public static List<org.opensearch.core.index.Index> randomIndexInstances()

    • randomInstance

      public static org.opensearch.cluster.metadata.DataStream randomInstance()

    • getClusterStateWithDataStreams

      public static org.opensearch.cluster.ClusterState getClusterStateWithDataStreams(List<org.opensearch.common.collect.Tuple<String,Integer>> dataStreams, List<String> indexNames)
      Constructs ClusterState with the specified data streams and indices.
      Parameters:
      dataStreams - The names of the data streams to create with their respective number of backing indices
      indexNames - The names of indices to create that do not back any data streams