Class MetadataCreateDataStreamService
java.lang.Object
org.elasticsearch.cluster.metadata.MetadataCreateDataStreamService
public class MetadataCreateDataStreamService
extends java.lang.Object
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
MetadataCreateDataStreamService.CreateDataStreamClusterStateUpdateRequest
-
Constructor Summary
Constructors Constructor Description MetadataCreateDataStreamService(ThreadPool threadPool, ClusterService clusterService, MetadataCreateIndexService metadataCreateIndexService)
-
Method Summary
Modifier and Type Method Description void
createDataStream(MetadataCreateDataStreamService.CreateDataStreamClusterStateUpdateRequest request, ActionListener<AcknowledgedResponse> finalListener)
ClusterState
createDataStream(MetadataCreateDataStreamService.CreateDataStreamClusterStateUpdateRequest request, ClusterState current)
static ComposableIndexTemplate
lookupTemplateForDataStream(java.lang.String dataStreamName, Metadata metadata)
static void
validateTimestampFieldMapping(java.lang.String timestampFieldName, MapperService mapperService)
-
Constructor Details
-
MetadataCreateDataStreamService
public MetadataCreateDataStreamService(ThreadPool threadPool, ClusterService clusterService, MetadataCreateIndexService metadataCreateIndexService)
-
-
Method Details
-
createDataStream
public void createDataStream(MetadataCreateDataStreamService.CreateDataStreamClusterStateUpdateRequest request, ActionListener<AcknowledgedResponse> finalListener) -
createDataStream
public ClusterState createDataStream(MetadataCreateDataStreamService.CreateDataStreamClusterStateUpdateRequest request, ClusterState current) throws java.lang.Exception- Throws:
java.lang.Exception
-
lookupTemplateForDataStream
public static ComposableIndexTemplate lookupTemplateForDataStream(java.lang.String dataStreamName, Metadata metadata) -
validateTimestampFieldMapping
public static void validateTimestampFieldMapping(java.lang.String timestampFieldName, MapperService mapperService) throws java.io.IOException- Throws:
java.io.IOException
-