@Test void applyMappingShouldNotThrowWhenIncrementalChanges() throws Exception { NodeMappingFactory.applyMapping(client, INDEX_NAME, getMappingsSources()); elasticSearch.awaitForElasticSearch(); assertThatCode(() -> NodeMappingFactory.applyMapping(client, INDEX_NAME, getOtherMappingsSources())) .doesNotThrowAnyException(); }
public static ReactorElasticSearchClient applyMapping(ReactorElasticSearchClient client, IndexName indexName, XContentBuilder mappingsSources) throws IOException { if (!mappingAlreadyExist(client, indexName)) { createMapping(client, indexName, mappingsSources); } return client; }
NodeMappingFactory { public static ReactorElasticSearchClient applyMapping(ReactorElasticSearchClient client, IndexName indexName, XContentBuilder mappingsSources) throws IOException { if (!mappingAlreadyExist(client, indexName)) { createMapping(client, indexName, mappingsSources); } return client; } }
NodeMappingFactory { public static ReactorElasticSearchClient applyMapping(ReactorElasticSearchClient client, IndexName indexName, XContentBuilder mappingsSources) throws IOException { if (!mappingAlreadyExist(client, indexName)) { createMapping(client, indexName, mappingsSources); } return client; }  }
NodeMappingFactory { public static ReactorElasticSearchClient applyMapping(ReactorElasticSearchClient client, IndexName indexName, XContentBuilder mappingsSources) throws IOException { if (!mappingAlreadyExist(client, indexName)) { createMapping(client, indexName, mappingsSources); } return client; }  static ReactorElasticSearchClient applyMapping(ReactorElasticSearchClient client, IndexName indexName, XContentBuilder mappingsSources); @SuppressWarnings("deprecation") static boolean mappingAlreadyExist(ReactorElasticSearchClient client, IndexName indexName); static void createMapping(ReactorElasticSearchClient client, IndexName indexName, XContentBuilder mappingsSources); }
NodeMappingFactory { public static ReactorElasticSearchClient applyMapping(ReactorElasticSearchClient client, IndexName indexName, XContentBuilder mappingsSources) throws IOException { if (!mappingAlreadyExist(client, indexName)) { createMapping(client, indexName, mappingsSources); } return client; }  static ReactorElasticSearchClient applyMapping(ReactorElasticSearchClient client, IndexName indexName, XContentBuilder mappingsSources); @SuppressWarnings("deprecation") static boolean mappingAlreadyExist(ReactorElasticSearchClient client, IndexName indexName); static void createMapping(ReactorElasticSearchClient client, IndexName indexName, XContentBuilder mappingsSources); static final String DEFAULT_MAPPING_NAME; static final String BOOLEAN; static final String TYPE; static final String LONG; static final String DOUBLE; static final String INDEX; static final String NOT_ANALYZED; static final String STRING; static final String TEXT; static final String KEYWORD; static final String PROPERTIES; static final String ROUTING; static final String REQUIRED; static final String DATE; static final String FORMAT; static final String NESTED; static final String FIELDS; static final String RAW; static final String SPLIT_EMAIL; static final String ANALYZER; static final String NORMALIZER; static final String SEARCH_ANALYZER; static final String SNOWBALL; static final String IGNORE_ABOVE; }