DateIndexNameFactoryTests.java 文件源码

public void testSpecifyOptionalSettings() throws Exception {
    DateIndexNameProcessor.Factory factory = new DateIndexNameProcessor.Factory();
    Map<String, Object> config = new HashMap<>();
    config.put("field", "_field");
    config.put("index_name_prefix", "_prefix");
    config.put("date_rounding", "y");
    config.put("date_formats", Arrays.asList("UNIX", "UNIX_MS"));

    DateIndexNameProcessor processor = factory.create(null, null, config);
    assertThat(processor.getDateFormats().size(), Matchers.equalTo(2));

    config = new HashMap<>();
    config.put("field", "_field");
    config.put("index_name_prefix", "_prefix");
    config.put("date_rounding", "y");
    config.put("index_name_format", "yyyyMMdd");

    processor = factory.create(null, null, config);
    assertThat(processor.getIndexNameFormat(), Matchers.equalTo("yyyyMMdd"));

    config = new HashMap<>();
    config.put("field", "_field");
    config.put("index_name_prefix", "_prefix");
    config.put("date_rounding", "y");
    config.put("timezone", "+02:00");

    processor = factory.create(null, null, config);
    assertThat(processor.getTimezone(), Matchers.equalTo(DateTimeZone.forOffsetHours(2)));

    config = new HashMap<>();
    config.put("field", "_field");
    config.put("index_name_prefix", "_prefix");
    config.put("date_rounding", "y");

    processor = factory.create(null, null, config);
    assertThat(processor.getIndexNamePrefix(), Matchers.equalTo("_prefix"));
}