Package org.graylog2.indexer.datastream

Class DataStreamServiceImpl

java.lang.Object

org.graylog2.indexer.datastream.DataStreamServiceImpl

All Implemented Interfaces:

DataStreamService

public class DataStreamServiceImpl
extends Object
implements DataStreamService

Constructor Summary

Constructors

Constructor	Description
DataStreamServiceImpl(DataStreamAdapter dataStreamAdapter, IndexFieldTypesService indexFieldTypesService, int replicas)
DataStreamServiceImpl(DataStreamAdapter dataStreamAdapter, IndexFieldTypesService indexFieldTypesService, IndexSetDefaultTemplateService indexSetDefaultTemplateService)

Method Summary

Modifier and Type	Method	Description
void	createDataStream(String dataStreamName, String timestampField, Map<String,Map<String,String>> mappings, Policy ismPolicy)	Create a data stream.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DataStreamServiceImpl

@Inject
public DataStreamServiceImpl(DataStreamAdapter dataStreamAdapter,
 IndexFieldTypesService indexFieldTypesService,
 IndexSetDefaultTemplateService indexSetDefaultTemplateService)

DataStreamServiceImpl

public DataStreamServiceImpl(DataStreamAdapter dataStreamAdapter,
 IndexFieldTypesService indexFieldTypesService,
 int replicas)

Method Details

createDataStream

public void createDataStream(String dataStreamName,
 String timestampField,
 Map<String,Map<String,String>> mappings,
 Policy ismPolicy)

Description copied from interface: DataStreamService

Create a data stream. This will create a data stream template with the given mappings, adding a timestamp mapping if none is specified for the timestampField in the mappings. Mappings will be made available to the FieldTypeMappingsService. If no data stream with the given name exists, the data stream will be created. A policy for handling lifecycle management of the data stream and its backing indices can be specified. Existing templates, mappings and policies will be updated.

Specified by:

createDataStream in interface DataStreamService

Parameters:

dataStreamName - name of the data stream

timestampField - timestamp field

mappings - field type mappings in the data stream

ismPolicy - ism policy for backing index lifecycle management