From 1ad1e448eeee2112239ce090da4c7d54b08c2300 Mon Sep 17 00:00:00 2001 From: PengyuDeng <89559616+PengyuDeng@users.noreply.github.com> Date: Mon, 24 Jun 2024 10:34:59 +0800 Subject: [PATCH] =?UTF-8?q?refactor(=E5=9F=BA=E7=A1=80=E6=A8=A1=E5=9D=97):?= =?UTF-8?q?=20=20=E4=BC=98=E5=8C=96es=E7=B4=A2=E5=BC=95=E9=85=8D=E7=BD=AE,?= =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E6=8B=93=E5=B1=95=E6=80=A7=E3=80=82=20(#526)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../elastic/search/index/ElasticSearchIndexProperties.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/jetlinks-components/elasticsearch-component/src/main/java/org/jetlinks/community/elastic/search/index/ElasticSearchIndexProperties.java b/jetlinks-components/elasticsearch-component/src/main/java/org/jetlinks/community/elastic/search/index/ElasticSearchIndexProperties.java index bd397e75..b5fdabdc 100644 --- a/jetlinks-components/elasticsearch-component/src/main/java/org/jetlinks/community/elastic/search/index/ElasticSearchIndexProperties.java +++ b/jetlinks-components/elasticsearch-component/src/main/java/org/jetlinks/community/elastic/search/index/ElasticSearchIndexProperties.java @@ -4,6 +4,10 @@ import lombok.*; import org.elasticsearch.common.settings.Settings; import org.springframework.boot.context.properties.ConfigurationProperties; +import java.util.HashMap; +import java.util.Map; +import java.util.function.Function; + @Getter @Setter @Builder @@ -16,11 +20,14 @@ public class ElasticSearchIndexProperties { private int numberOfReplicas = 0; + private Map options = new HashMap<>(); + public Settings toSettings() { return Settings.builder() .put("number_of_shards", Math.max(1, numberOfShards)) .put("number_of_replicas", numberOfReplicas) + .putProperties(options, Function.identity()) .build(); } }