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)
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
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
-