Package org.elasticsearch.cluster.metadata

Class MetadataCreateDataStreamService

java.lang.Object

org.elasticsearch.cluster.metadata.MetadataCreateDataStreamService

public class MetadataCreateDataStreamService
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final 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(String dataStreamName, Metadata metadata)
static void	validateTimestampFieldMapping(MappingLookup mappingLookup)

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 Exception

Throws:

Exception

lookupTemplateForDataStream

public static ComposableIndexTemplate lookupTemplateForDataStream(String dataStreamName,
 Metadata metadata)

validateTimestampFieldMapping

public static void validateTimestampFieldMapping(MappingLookup mappingLookup)
                                          throws IOException

Throws:

IOException